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(-)
