This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
from dbf1d62ee4b [FLINK-28544][python][e2e] Clean up python environment
after e2e tests
new ac6007116a1 [FLINK-23528][datastream] Let CollectSinkOperator publish
results in #close.
new f2e265f8192 [FLINK-23528][connectors/kinesis] Use proper mock of
ExecutorService in KinesisDataFetcherTest.
new 803dcad14e5 [FLINK-23528][connectors/kinesis] Gracefully shutdown
shard consumer to avoid InterruptionExceptions.
new 8fb2c3a4cf3 [FLINK-23528][connectors/kinesis] Reenable
FlinkKinesisITCase and rewrite stopWithSavepoint.
new 7cd5fe93035 [FLINK-23528][connectors/kinesis]Graceful shutdown of
Kinesis Consumer in EFO mode
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kinesis/internals/KinesisDataFetcher.java | 7 +-
.../publisher/fanout/FanOutShardSubscriber.java | 3 +-
.../connectors/kinesis/FlinkKinesisITCase.java | 189 +++++++++++++++------
.../kinesis/internals/KinesisDataFetcherTest.java | 2 +-
.../fanout/FanOutShardSubscriberTest.java | 20 +++
.../testutils/FakeKinesisBehavioursFactory.java | 25 +--
.../testutils/TestableKinesisDataFetcher.java | 108 ++++++++----
.../api/operators/collect/CollectSinkOperator.java | 4 +-
8 files changed, 254 insertions(+), 104 deletions(-)
