slachiewicz commented on PR #279: URL: https://github.com/apache/flink-connector-kafka/pull/279#issuecomment-5471408994
One more to add to the coordination list from my earlier comment: #295 ([FLINK-40469](https://issues.apache.org/jira/browse/FLINK-40469)) checkpoints `pendingReportedSplitsByReader` into `DynamicKafkaSourceEnumState` (serializer bump to VERSION_4) and modifies `DynamicKafkaSourceEnumeratorRecoveryTest.java` — the same filename as the new recovery test class in this PR, in the same recovery-window area of `DynamicKafkaSourceEnumerator`. Suggested landing order remains: the small approved ones first — #285, #288, #289 ([FLINK-40137](https://issues.apache.org/jira/browse/FLINK-40137), approved) — then this PR and #295 rebase on top; #289 in particular touches the same recovery-gating state #295 checkpoints. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
