[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r815933181 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java ## @@ -272,6 +327,101 @@ publ

[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r815926295 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -509,17 +619,88 @@ public S

[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r815924963 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -509,17 +619,88 @@ public S

[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r814977189 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -69,13 +75,82 @@ * the le

[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r814672839 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -132,31 +197,27 @@ public K

[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r813145701 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -132,31 +197,27 @@ public K