This is an automated email from the ASF dual-hosted git repository.
renqs pushed a change to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0bd63884ebc [hotfix] Sort NOTICE dependencies in alphabetical order
add 09fb503f0f3 [FLINK-31319][connectors/kafka] Fix kafka new source
partitionDiscoveryIntervalMs error condition check cause bounded source can not
quit
No new revisions were added by this update.
Summary of changes:
.../source/enumerator/KafkaSourceEnumerator.java | 2 +-
.../source/enumerator/KafkaEnumeratorTest.java | 113 +++++++++++++++++++--
2 files changed, 108 insertions(+), 7 deletions(-)
