This is an automated email from the ASF dual-hosted git repository.
renqs pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 26eeabfdd1f [FLINK-29132][rest] Cleanup subtask attempt metrics
according to the JobDetails to avoid memory leak.
add 3e883e687d2 [FLINK-29153][connector/kafka] Retry
KafkaConsumer#commitAsync on WakeupException in KafkaConsumerThread
No new revisions were added by this update.
Summary of changes:
.../kafka/internals/KafkaConsumerThread.java | 20 +++++++++++++++++---
1 file changed, 17 insertions(+), 3 deletions(-)
