You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2022/06/14 07:33:31 UTC
[flink] branch master updated (2e37a063685 -> 2b89dfe0d4c)
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 2e37a063685 [FLINK-27658][runtime] SafetyNetWrapperClassLoader expose addURL method to allow registering jar dynamically
add 2b89dfe0d4c [FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case
No new revisions were added by this update.
Summary of changes:
.../source/reader/KafkaPartitionSplitReader.java | 29 ++++--
.../connector/kafka/source/KafkaSourceITCase.java | 110 ++++++++++++++++-----
.../kafka/source/reader/KafkaSourceReaderTest.java | 32 ++++++
.../kafka/testutils/KafkaSourceTestEnv.java | 4 +
4 files changed, 144 insertions(+), 31 deletions(-)