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