You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by wa...@apache.org on 2021/11/18 08:10:57 UTC
[flink] branch release-1.14 updated (e68e30d -> 9d114b0)
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e68e30d [FLINK-24409][kafka] Log PendingRecords metrics name if record lag collection fails
add 9d114b0 [FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods
No new revisions were added by this update.
Summary of changes:
.../kubernetes/KubernetesResourceManagerDriver.java | 5 +++--
.../kubeclient/decorators/ExternalServiceDecorator.java | 2 +-
.../kubeclient/decorators/InternalServiceDecorator.java | 2 +-
.../kubeclient/factory/KubernetesJobManagerFactory.java | 6 +-----
.../parameters/KubernetesJobManagerParameters.java | 9 ++++++---
.../kubeclient/parameters/KubernetesParameters.java | 3 +++
.../parameters/KubernetesTaskManagerParameters.java | 7 ++++++-
.../apache/flink/kubernetes/utils/KubernetesUtils.java | 17 ++++++++++++++---
.../decorators/ExternalServiceDecoratorTest.java | 1 -
.../decorators/InternalServiceDecoratorTest.java | 1 -
.../factory/KubernetesJobManagerFactoryTest.java | 9 +++++----
.../parameters/AbstractKubernetesParametersTest.java | 5 +++++
12 files changed, 45 insertions(+), 22 deletions(-)