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 c88189f [FLINK-26146] Adapt scala tests to cover native snapshots
migration
add e98eeeb [FLINK-25977][connectors/kinesis] Closing HTTP & SDK clients
in sink & integration tests.
No new revisions were added by this update.
Summary of changes:
.../kinesis/sink/KinesisDataStreamsSinkWriter.java | 22 +++++++++++++--------
.../kinesis/sink/KinesisDataStreamsSinkITCase.java | 8 ++++++--
.../kinesis/testutils/KinesaliteContainer.java | 23 +++++++++++++---------
.../table/test/KinesisDataStreamsTableApiIT.java | 19 ++++++++++--------
4 files changed, 45 insertions(+), 27 deletions(-)