(flink) branch master updated: [hotfix][kubernetes] Minor polish codes in flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java to reduce premature and unnecessary variable declarations (#26512)

[panyuepeng]

This is an automated email from the ASF dual-hosted git repository.

RocMarshal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 63798c68ca1 [hotfix][kubernetes] Minor polish codes in 
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java
 to reduce premature and unnecessary variable declarations (#26512)
63798c68ca1 is described below

commit 63798c68ca1d6d7b03a6c88070a3d494871817a8
Author: Jiaan Geng <belie...@163.com>
AuthorDate: Thu May 7 10:31:21 2026 +0800

    [hotfix][kubernetes] Minor polish codes in 
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java
 to reduce premature and unnecessary variable declarations (#26512)
    
    Co-authored-by: Yuepeng Pan <hipanyuep...@gmail.com>
---
 .../java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 36a1242b2a5..7bc10e489e3 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 @@ public class KubernetesSessionCli {
         try {
             final ClusterClient<String> 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 @@ public class KubernetesSessionCli {
             }
 
             try {
-                if (!detached) {
+                if (configuration.get(DeploymentOptions.ATTACHED)) {
                     Tuple2<Boolean, Boolean> continueRepl = new Tuple2<>(true, 
false);
                     try (BufferedReader in = new BufferedReader(new 
InputStreamReader(System.in))) {
                         while (continueRepl.f0) {