This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 200be71 [FLINK-19750][connector/kafka] Fix bug of not opening
DeserializationSchema when FlinkKafkaConsumerBase recovers from state (#13785)
add 4b6d0e6 [FLINK-19068][k8s] Improve log readability against duplicated
pod termination events.
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java | 2 +-
.../flink/runtime/resourcemanager/active/ActiveResourceManager.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
