ClickHouse executeBatch error about flink-connector-clickhouse

[kongyuan1990]

use tag release-1.12.0

[kongyuan1990]

and, sink to clickhouse, lost some data
But when I use datastream jdbc connector , No data loss occurred

[itinycheng]

This info is not enough for me to find the problem.
If it happens accidentally, it may be caused by dirty data (I'm not sure).

This exception occurs during sending data to the server-side in clickhouse-jdbc.jar, you'd better do some breakpoint tests, where the exception occurred:

[kongyuan1990]

I tried three test cases.

case 1: use datastream jdbc connector;

successed sink to clickhouse 9408 datas

case 2: use tag release-1.12.0

successed sink to clickhouse 8578 datas， lost 830 datas , no exception occurred

I still can't find the reason for the loss of data.

case 3: use this source code (https://github.com/liekkassmile/flink-connector-clickhouse)

successed sink to clickhouse 9408 datas

[itinycheng]

OK, can you email or WX me to talk some details about this?

[kongyuan1990]

WX：snake_kong

[itinycheng]

Tag: release-1.12.0 has a thread-safe bug that causes this problem, bugfix commit: bb4f078, 3451515
Use branch release-1.12 to avoid this issue and I have deleted the tag to prevent more people encounter this.