Hi Egor,
Thanks for reporting this! There is some changes in MySQL binlog offset
comparing logic in FLINK-37191[1]. The MySQL binlog filename comparison code
(which isn’t null-safe) throwing an NPE has been there for a long time, but the
execution flow might have changed and triggers this probl
Hi!
I tried switching an application from Flink CDC version 3.3.0 to Flink
CDC version 3.4.0 and encountered the following exception:
(using flink-sql-connector-mysql-cdc and flink 1.20)
java.lang.RuntimeException: SplitFetcher thread 0 received unexpected
exception while polling the records
