This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1de3d63 [FLINK-17170][kinesis] Fix deadlock during
stop-with-savepoint.
add fc886c7 [FLINK-20114][connector/kafka] KafkaSourceReader should not
commit offsets for partitions whose offsets have not been initialized.
add 0786be4 [hotfix][connector/kafka] Reduce the offset commit logging
verbosity from INFO to DEBUG.
add 5909ecf [FLINK-20114][connector/common] SourceOperatorStreamTask
should update the numRecordsOutCount metric
add 79ea3bf [FLINK-20114][connector/kafka] KafkaSourceEnumerator should
close the admin client early if periodic partition discovery is disabled.
add 62fc4a1 [hotfix][connector/kafka] Remove the unused close.timeout.ms
config.
add c618de9 [FLINK-20114][connector/kafka]
PartitionOffsetsRetrieverImpl.committedOffsets() should handle the case without
committed offsets.
add 1eeeaea [FLINK-20114][connector/kafka] SourceOperatorStreamTask
should check the committed offset first before using OffsetResetStrategy.
add a0ba502 [FLINK-20114][connector/kafka] Auto offset commit should be
disabled by default.
add be33d47 [FLINK-20114][connector/kafka] Remove duplicated warning and
remove redundant default value for partition.discovery.interval.ms
No new revisions were added by this update.
Summary of changes:
.../connector/kafka/source/KafkaSourceBuilder.java | 9 +++-----
.../connector/kafka/source/KafkaSourceOptions.java | 8 +-------
.../source/enumerator/KafkaSourceEnumerator.java | 17 +++++++++++++--
.../initializer/SpecifiedOffsetsInitializer.java | 6 ++++++
.../kafka/source/reader/KafkaSourceReader.java | 24 ++++++++++++++--------
.../initializer/OffsetsInitializerTest.java | 21 ++++++++++++++-----
.../kafka/source/reader/KafkaSourceReaderTest.java | 14 +++++++++++++
.../io/StreamMultipleInputProcessorFactory.java | 6 +++++-
.../runtime/tasks/SourceOperatorStreamTask.java | 18 ++++++++++++++--
9 files changed, 92 insertions(+), 31 deletions(-)
