[GitHub] [flink] tillrohrmann commented on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-11-08 Thread GitBox
tillrohrmann commented on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-723639551 I've fixed the problem with a1ec69a75f7e3512b8de698619d53f5d89897973 This is an automated message from the

[GitHub] [flink] tillrohrmann commented on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-11-08 Thread GitBox
tillrohrmann commented on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-723637114 I think this PR breaks the master @becketqin because `MockSplitEnumeratorContext` does not implement `SplitEnumeratorContext.runInCoordinatorThread`