如何提升Flink写入tidb的速率

图里 withBatchIntervalMs 这个 1000ms 说起来不少了,不过还是可以试试把 withBatchSize 设置上给一个比较大的 batch 尺寸上限看看。

另外建议直接使用 TiBigData 项目的 connector,目前他的写入端实现虽然也是用的 JDBC 但默认开启了上面的 batch 模式,也可以很方便的用 table properties 来修改。然后这块儿还会不断的演进,后面会加上 Global Transaction 的能力 bypass 掉 TiDB,在性能和事务尺寸上都能够达到更好的状态。