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 e84c1b4 [FLINK-23692][ui] Clarify text on 'Cancel Job' confirmation
button
add bbae6a1 [FLINK-23802][kinesis][efo] Request next record from the
Flink source thread rather than the AWS SDK response thread. Increase Read
Timeout to 6m, higher than the maximum Shard subscription duration (5m) and
enable TCP keep alive.
No new revisions were added by this update.
Summary of changes:
.../kinesis/config/ConsumerConfigConstants.java | 7 +-
.../publisher/fanout/FanOutShardSubscriber.java | 17 +--
.../kinesis/proxy/KinesisProxyV2Factory.java | 6 +
.../connectors/kinesis/util/AwsV2Util.java | 14 ++-
.../fanout/FanOutRecordPublisherTest.java | 18 ++-
.../fanout/FanOutShardSubscriberTest.java | 2 +-
.../kinesis/proxy/KinesisProxyV2FactoryTest.java | 88 +++++++++++++
.../FakeKinesisFanOutBehavioursFactory.java | 138 +++++++++++++++------
.../connectors/kinesis/util/AwsV2UtilTest.java | 33 ++++-
9 files changed, 260 insertions(+), 63 deletions(-)
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2FactoryTest.java
