2309859381

Writing data to Clickhouse(20.6.3.28,22.8.4.7) using Flink(1.14.5) causes data duplication

2

JDBC 0.3.2+ can cause such problems. this is my code ` public void createConnection() throws Exception { String insertStr = insertStr(this.tableColums); String url = "jdbc:clickhouse://" + host + "?socket_timeout=300000"; Connection...