When using a table with a TableRowExtenderColumn the following exception happens when the data in the table changes (and/remove/update records) frequently (2 or more changes per second): ...
We are leveraging flink-connector-clickhouse to read and write data to clickhouse from custom written DataStream Api KeyedCoProcessFunction. Implementation uses AbstractClickHouseOutputFormat builder ...