[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r426109436 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -96,9 +98,10 @@ * Watch the

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425563975 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425551475 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425546588 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -96,9 +98,10 @@ * Watch the

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r411093370 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesPodsWatcher.java ## @@ -0,0 +1,79 @@ +/* +

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r411092488 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -148,6 +156,7 @@ protected void

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r411092429 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception URL: https://github.com/apache/flink/pull/11010#discussion_r375818015 ## File path: