This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2eb5d1c [FLINK-21942][tests] Introduce TestingJobLeaderIdService and
use it in ResourceManagerTest
new 2be1533 [FLINK-21817][connector/kafka] Remove mapping of reader id to
split assignments from Kafka enumerator and its state
new dc3d070 [FLINK-21159][connector/kafka] Signal NoMoreSplitsEvent to
all readers even without any assignments
new b96e67a [hotfix][connector/kafka] Fix incorrect lambda
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/connector/kafka/source/KafkaSource.java | 2 +-
.../source/enumerator/KafkaSourceEnumState.java | 13 ++-
.../enumerator/KafkaSourceEnumStateSerializer.java | 67 ++++++++++++-
.../source/enumerator/KafkaSourceEnumerator.java | 111 ++++++++++++---------
.../connector/kafka/source/KafkaSourceITCase.java | 25 +++++
.../source/enumerator/KafkaEnumeratorTest.java | 52 ++++++++--
.../KafkaSourceEnumStateSerializerTest.java | 108 ++++++++++++++++++++
.../connector/source/SplitEnumeratorContext.java | 2 +-
8 files changed, 310 insertions(+), 70 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializerTest.java
