This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6bb345d [FLINK-5717][datastream] Fix NPE and lost timer during window
merging for ContinuousProcessingTimeTrigger
add 45a24e4 [FLINK-21933][kinesis] EFO consumer treats interrupts as
retryable exceptions (#15347)
No new revisions were added by this update.
Summary of changes:
.../kinesis/internals/KinesisDataFetcher.java | 15 ++++++
.../kinesis/internals/ShardConsumer.java | 34 ++++++++++--
.../internals/publisher/RecordPublisher.java | 5 +-
.../publisher/fanout/FanOutRecordPublisher.java | 8 +++
.../publisher/fanout/FanOutShardSubscriber.java | 29 +++++++++-
.../kinesis/internals/KinesisDataFetcherTest.java | 63 +++++++++++++++-------
.../kinesis/internals/ShardConsumerFanOutTest.java | 48 +++++++++++++++++
.../kinesis/internals/ShardConsumerTestUtils.java | 17 +++++-
.../fanout/FanOutRecordPublisherTest.java | 20 ++++++-
.../fanout/FanOutShardSubscriberTest.java | 17 ++++++
10 files changed, 226 insertions(+), 30 deletions(-)
