[jira] [Created] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

2024-10-30 Thread Alberto Lago (Jira)
Alberto Lago created FLINK-36630: Summary: kafka-connector random WakeupException after enabling watermark alignment Key: FLINK-36630 URL: https://issues.apache.org/jira/browse/FLINK-36630 Project

kafka-connector random WakeupException after enabling watermark alignment

2024-10-29 Thread Alberto Lago
Hello, in Flink 19, AWS managed Flink flink-connector-kafka:3.3.0-1.19 After i enable watermark alignment at KafkaSource, It starts throwing uncaught WakeupException. It happens: * On every checkpoint unless i disable offset committing: setProperty(KafkaSourceOptions.COMMIT_OFFSETS_ON_CHECKPOI