diff --git a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java index 36a1242b2a56e..7bc10e489e3a6 100644 --- a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java +++ b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java @@ -102,7 +102,6 @@ private int run(String[] args) throws FlinkException, CliArgsException { try { final ClusterClient clusterClient; String clusterId = kubernetesClusterClientFactory.getClusterId(configuration); - final boolean detached = !configuration.get(DeploymentOptions.ATTACHED); final FlinkKubeClient kubeClient = FlinkKubeClientFactory.getInstance().fromConfiguration(configuration, "client"); @@ -123,7 +122,7 @@ private int run(String[] args) throws FlinkException, CliArgsException { } try { - if (!detached) { + if (configuration.get(DeploymentOptions.ATTACHED)) { Tuple2 continueRepl = new Tuple2<>(true, false); try (BufferedReader in = new BufferedReader(new InputStreamReader(System.in))) { while (continueRepl.f0) {