Efrat19 commented on PR #285: URL: https://github.com/apache/flink-connector-kafka/pull/285#issuecomment-5491809463
> getSentSourceEvent() is public and I will switch to it. Thanks - please update commit description accordingly > Removing the race properly means changing `MockSplitEnumeratorContext` in [flink-core](https://issues.apache.org/jira/browse/FLINK-core) to copy on the main executor and deep-copy the value lists. Happy to file that separately if you think it is worth doing. Sounds like a simple fix through `ConcurrentHashMap` - can we at least have a ticket? > It will not remove the ConcurrentModificationException though Understood, would be nice to link to the ticket for the flink-core fix -- 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]
