[ https://issues.apache.org/jira/browse/FLINK-19545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227889#comment-17227889 ]
Yang Wang commented on FLINK-19545: ----------------------------------- We already have some IT cases for the critical methods. Then we just need to add a E2E test in this issue. {code:java} # Run the ITCases run_mvn test -Dtest=org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClientITCase run_mvn test -Dtest=org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElectorITCase run_mvn test -Dtest=org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionAndRetrievalITCase run_mvn test -Dtest=org.apache.flink.kubernetes.highavailability.KubernetesStateHandleStoreITCase {code} > Add e2e test for native Kubernetes HA > ------------------------------------- > > Key: FLINK-19545 > URL: https://issues.apache.org/jira/browse/FLINK-19545 > Project: Flink > Issue Type: Sub-task > Components: Tests > Reporter: Yang Wang > Assignee: Yang Wang > Priority: Major > Fix For: 1.12.0 > > > We could use minikube for the E2E tests. Start a Flink session/application > cluster on K8s, kill one TaskManager pod or JobManager Pod and wait for the > job recovered from the latest checkpoint successfully. > {panel} > {panel} > |{{kubectl }}{{exec}} {{-it \{pod_name} -- }}{{/bin/sh}} {{-c }}{{"kill 1"}}| -- This message was sent by Atlassian Jira (v8.3.4#803005)