Re: Kafka SQL Connector loses data if deserialization error occures

2024-10-09 Thread Ilya Karpov
Finally I found that in order to execute many insert statements in one job I need to use STATEMENT SET. This solved the problem. ср, 9 окт. 2024 г. в 12:17, Ilya Karpov : > During this morning debug I've found that if I comment one of two insert > expressions and submit sql, then only one job wil

Re: Kafka SQL Connector loses data if deserialization error occures

2024-10-09 Thread Ilya Karpov
During this morning debug I've found that if I comment one of two insert expressions and submit sql, then only one job will be created in the flink cluster. If a corrupted message causes failure of this job then flink behaves correctly: checkpoint does not happen, offset is not committed! Modified