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 2b7bb05 [FLINK-22424][network] Prevent releasing
PipelinedSubpartition while Task can still write to it
add 23ab254 [FLINK-22479[Kinesis][Consumer] Potential lock-up under error
condition
No new revisions were added by this update.
Summary of changes:
.../kinesis/config/ConsumerConfigConstants.java | 6 +
.../kinesis/internals/KinesisDataFetcher.java | 65 +++++++---
.../publisher/fanout/FanOutRecordPublisher.java | 5 +-
.../fanout/FanOutRecordPublisherConfiguration.java | 15 +++
.../publisher/fanout/FanOutShardSubscriber.java | 144 ++++++++++++++++-----
.../kinesis/internals/KinesisDataFetcherTest.java | 76 +++++++++--
.../FanOutRecordPublisherConfigurationTest.java | 50 +++++--
.../fanout/FanOutShardSubscriberTest.java | 72 ++++++++++-
.../FakeKinesisFanOutBehavioursFactory.java | 22 ++++
.../testutils/TestableKinesisDataFetcher.java | 18 ++-
10 files changed, 383 insertions(+), 90 deletions(-)
