XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467504153
##########
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElectorITCase.java:
##########
@@ -110,4 +114,67 @@ void testMultipleKubernetesLeaderElectors() throws
Exception {
kubernetesExtension.getFlinkKubeClient().deleteConfigMap(leaderConfigMapName).get();
}
}
+
+ /**
+ * This test verifies that the {@link KubernetesLeaderElector} is able to
handle scenario where
+ * the lease cannot be renewed.
+ *
+ * <p>See FLINK-34007 for further details.
+ */
+ @Test
+ void testLeaderElectorLifecycleManagement() throws Exception {
Review Comment:
Good point. I moved the ConfigMap lifecycle management into separate
per-test methods.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
