This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3dc43e6 [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher
shutting down
add d332ff4 [FLINK-20088][kinesis] Fix issue encountered when Polling
consumer using timestamp with empty shard
No new revisions were added by this update.
Summary of changes:
.../publisher/polling/PollingRecordPublisher.java | 19 ++++++++++++--
.../kinesis/internals/ShardConsumerTest.java | 18 +++++++++++++
.../testutils/FakeKinesisBehavioursFactory.java | 30 ++++++++++++++++++++++
3 files changed, 65 insertions(+), 2 deletions(-)
