This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from cadf4b35fb6 [FLINK-31478][python] Fix ds.execute_and_collect to
support nested tuple
add a5f085e042b [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 | 132 +++++++++++++++++----
2 files changed, 108 insertions(+), 26 deletions(-)
