naivedogger opened a new pull request, #4480: URL: https://github.com/apache/flink-cdc/pull/4480
This closes FLINK-40202. `HybridSplitAssigner#open()` initializes enumerator metrics *after* calling `snapshotSplitAssigner.open()`, which has already started an asynchronous splitting thread that mutates `remainingSplits`. `initEnumeratorMetrics()` then iterates that list without synchronization, causing the following exception: <img width="2510" height="892" alt="image" src="https://github.com/user-attachments/assets/2395e8d9-f505-49ba-9b66-57caf06e1d85"; /> The fix initializes the enumerator metrics before opening the snapshot assigner, so metrics are seeded before the background splitting thread starts. -- 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]
