You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by jq...@apache.org on 2020/06/15 17:42:07 UTC

[flink] branch master updated (889705c -> f883f11)

This is an automated email from the ASF dual-hosted git repository.

jqin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 889705c  [FLINK-15362] Bump Kafka connector to 2.4.1
     add f883f11  [FLINK-18162][connector/common] Serialize the splits in the AddSplitsEvent.

No new revisions were added by this update.

Summary of changes:
 .../coordinator/SourceCoordinatorContext.java      | 13 ++++++++---
 .../coordinator/SourceCoordinatorProvider.java     |  4 +++-
 .../flink/runtime/source/event/AddSplitEvent.java  | 25 ++++++++++++++++------
 .../coordinator/SourceCoordinatorContextTest.java  | 10 ++++-----
 .../source/coordinator/SourceCoordinatorTest.java  | 12 +++++++++--
 .../coordinator/SourceCoordinatorTestBase.java     |  2 ++
 .../streaming/api/operators/SourceOperator.java    |  8 ++++++-
 .../api/operators/SourceOperatorTest.java          |  6 ++++--
 .../tasks/SourceOperatorStreamTaskTest.java        |  4 +++-
 9 files changed, 62 insertions(+), 22 deletions(-)