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 0875db3 [FLINK-20897][table-planner] Support batch mode in
StreamTableEnvironment
add b48607b [FLINK-23705][connectors/kinesis] Unregistering metric
reporting for closed shards
No new revisions were added by this update.
Summary of changes:
.../kinesis/internals/ShardConsumer.java | 2 +
.../metrics/ShardConsumerMetricsReporter.java | 10 ++++
.../internals/DynamoDBStreamsDataFetcherTest.java | 5 +-
.../kinesis/internals/ShardConsumerTest.java | 28 ++++++++++
.../kinesis/internals/ShardConsumerTestUtils.java | 64 +++++++++++++++++++---
.../polling/PollingRecordPublisherFactoryTest.java | 6 +-
.../polling/PollingRecordPublisherTest.java | 8 ++-
.../metrics/ShardConsumerMetricsReporterTest.java | 15 +++++
.../connectors/kinesis/testutils/TestUtils.java | 4 +-
9 files changed, 126 insertions(+), 16 deletions(-)
