You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/11/17 16:46:09 UTC
[flink] branch release-1.14 updated (5a0609a -> e68e30d)
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5a0609a [FLINK-22419] Wait unlimited in RpcEndpointTest.testCallAsyncTimeout
add 9ba8a29 [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for topics containing periods
add e68e30d [FLINK-24409][kafka] Log PendingRecords metrics name if record lag collection fails
No new revisions were added by this update.
Summary of changes:
.../source/metrics/KafkaSourceReaderMetrics.java | 8 ++--
.../reader/KafkaPartitionSplitReaderTest.java | 47 ++++++++++++++--------
2 files changed, 35 insertions(+), 20 deletions(-)