You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/05/16 12:42:27 UTC
[flink] branch master updated (367c613 -> 4c65864)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 367c613 [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
add 4c65864 [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception
No new revisions were added by this update.
Summary of changes:
.../kubernetes/KubernetesResourceManager.java | 25 ++++-
.../kubeclient/Fabric8FlinkKubeClient.java | 39 ++-----
.../kubernetes/kubeclient/FlinkKubeClient.java | 8 +-
.../resources/KubernetesPodsWatcher.java | 75 ++++++++++++++
...KubernetesService.java => KubernetesWatch.java} | 14 ++-
.../resources/KubernetesPodsWatcherTest.java | 112 +++++++++++++++++++++
6 files changed, 230 insertions(+), 43 deletions(-)
create mode 100644 flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesPodsWatcher.java
copy flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/{KubernetesService.java => KubernetesWatch.java} (77%)
create mode 100644 flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesPodsWatcherTest.java