[FLINK-27261] Disable 'web.cancel.enable' for session cluster

This closes #198.
apache · May 11, 2022 · 60654f4 · 60654f4
1 parent 6ce3d96
commit 60654f4
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/...perator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java b/...perator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java
@@ -134,12 +134,10 @@ protected FlinkConfigBuilder applyFlinkConfiguration() {
         // Adapt default rest service type from 1.15+
         setDefaultConf(
                 REST_SERVICE_EXPOSED_TYPE, KubernetesConfigOptions.ServiceExposedType.ClusterIP);
+        // Set 'web.cancel.enable' to false to avoid users accidentally cancelling jobs.
+        setDefaultConf(CANCEL_ENABLE, false);
 
         if (spec.getJob() != null) {
-            // Set 'web.cancel.enable' to false for application deployments to avoid users
-            // accidentally cancelling jobs.
-            setDefaultConf(CANCEL_ENABLE, false);
-
             // With last-state upgrade mode, set the default value of
             // 'execution.checkpointing.interval'
             // to 5 minutes when HA is enabled.

diff --git a/...tor/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java b/...tor/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java
@@ -146,6 +146,13 @@ public void testApplyFlinkConfiguration() {
         Assertions.assertEquals(
                 DEFAULT_CHECKPOINTING_INTERVAL,
                 configuration.get(ExecutionCheckpointingOptions.CHECKPOINTING_INTERVAL));
+
+        deployment = TestUtils.buildSessionCluster();
+        configuration =
+                new FlinkConfigBuilder(deployment, new Configuration())
+                        .applyFlinkConfiguration()
+                        .build();
+        Assertions.assertEquals(false, configuration.get(WebOptions.CANCEL_ENABLE));
     }
 
     @Test