Hi Nicholas,
You can take a look to JDBCSinkFunction and JDBCUpsertSinkFunction.
They can set something like flush batch max size just like vino mentioned.
JDBCUpsertOutputFormat also has a async thread to flush batch to JDBC
to avoid too high delay. In this way, the throughput can be improved wh
Hi Nick,
Can you provide more details? Are you using JDBCOutputFormat? If yes, can
`JDBCOutputFormatBuilder#setBatchInterval` help you?
Best,
Vino
Nicholas Walton 于2019年11月26日周二 下午9:20写道:
> I’m streaming records down to an Embedded Derby database, at a rate of
> around 200 records per second.