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:28 UTC
[flink] branch master updated (da8ef26 -> e192243)
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from da8ef26 [FLINK-24409][kafka] Log PendingRecords metrics name if record lag collection fails
add e192243 [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 | 5 +----
.../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(+), 21 deletions(-)