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(-)
