subject:"\[GitHub\] \[flink\] becketqin opened a new pull request #11554\: \[FLINK\-15101\]\[connector\/common\] Add SourceCoordinator implementation."

[GitHub] [flink] becketqin opened a new pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-04 Thread GitBox

becketqin opened a new pull request #11554: URL: https://github.com/apache/flink/pull/11554 ## What is the purpose of the change This patch is a part of [FLIP-27](https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface). It adds the implementation for

[GitHub] [flink] becketqin opened a new pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-03-28 Thread GitBox

becketqin opened a new pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554 ## What is the purpose of the change This patch is a part of