This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f191bec [hotfix][checkpoint] Fix the wrong parameters due to base
code change in StreamTaskFinalCheckpointsTest
add 2b1a9de [FLINK-25132][connector/kafka] Move record deserializing from
SplitFetcher to RecordEmitter to support object-reusing deserializer
No new revisions were added by this update.
Summary of changes:
.../flink/connector/kafka/source/KafkaSource.java | 20 +--
.../source/reader/KafkaPartitionSplitReader.java | 186 +++++++--------------
.../kafka/source/reader/KafkaRecordEmitter.java | 50 +++++-
.../kafka/source/reader/KafkaSourceReader.java | 14 +-
.../reader/fetcher/KafkaSourceFetcherManager.java | 21 ++-
.../connector/kafka/source/KafkaSourceITCase.java | 65 ++++---
.../reader/KafkaPartitionSplitReaderTest.java | 53 +++---
7 files changed, 201 insertions(+), 208 deletions(-)
