This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c7c95e5 [FLINK-21836][table] Support parsing special commands by
introducing ExtendedParser
add c7eb397 [FLINK-21661][kinesis] Fix fetch interval for polling
consumer (#15157)
add 888551e [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 +++++++++-
.../polling/AdaptivePollingRecordPublisher.java | 42 +++------------
.../publisher/polling/PollingRecordPublisher.java | 48 ++++++++++++++---
.../kinesis/internals/KinesisDataFetcherTest.java | 63 +++++++++++++++-------
.../kinesis/internals/ShardConsumerFanOutTest.java | 48 +++++++++++++++++
.../kinesis/internals/ShardConsumerTestUtils.java | 17 +++++-
.../fanout/FanOutRecordPublisherTest.java | 20 ++++++-
.../fanout/FanOutShardSubscriberTest.java | 17 ++++++
.../polling/PollingRecordPublisherTest.java | 29 +++++++++-
13 files changed, 301 insertions(+), 74 deletions(-)
