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 1e7732f18a8 [FLINK-28090][python] Support attachAsDataStream in Python
Table API
new 6080840e9c1 [FLINK-23528][datastream] Let CollectSinkOperator publish
results in #close.
new b589f9f29f5 [FLINK-23528][connectors/kinesis] Use proper mock of
ExecutorService in KinesisDataFetcherTest.
new 16393625ed5 [FLINK-23528][connectors/kinesis] Gracefully shutdown
shard consumer to avoid InterruptionExceptions.
new 7496b68d29f [FLINK-23528][connectors/kinesis] Reenable
FlinkKinesisITCase and rewrite stopWithSavepoint.
new 4bbf3194dc3 [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 | 187 +++++++++++++++------
.../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(+), 102 deletions(-)
