You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by re...@apache.org on 2023/03/17 09:26:37 UTC

[flink] branch release-1.17 updated (0bd63884ebc -> 09fb503f0f3)

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