(flink) branch release-2.0 updated: [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging (#26803)

[dianfu]

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

dianfu pushed a commit to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-2.0 by this push:
     new a06b43be4ae [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env 
vars in PythonEnvUtils logging (#26803)
a06b43be4ae is described below

commit a06b43be4aef6df04be741d2be2a5cba2587a0f3
Author: Niharika Sakuru <31803710+vssak...@users.noreply.github.com>
AuthorDate: Wed Jul 23 14:58:32 2025 -0400

    [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in 
PythonEnvUtils logging (#26803)
    
    
    Co-authored-by: Rahul Sud <rahul....@gmail.com>
---
 .../src/main/java/org/apache/flink/client/python/PythonEnvUtils.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java 
b/flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java
index 00cd8b4b022..3a5870b5f22 100644
--- 
a/flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java
+++ 
b/flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java
@@ -20,6 +20,7 @@ package org.apache.flink.client.python;
 
 import 
org.apache.flink.client.deployment.application.UnsuccessfulExecutionException;
 import org.apache.flink.configuration.ConfigConstants;
+import org.apache.flink.configuration.ConfigurationUtils;
 import org.apache.flink.configuration.ReadableConfig;
 import org.apache.flink.core.fs.Path;
 import org.apache.flink.python.util.PythonDependencyUtils;
@@ -368,10 +369,9 @@ final class PythonEnvUtils {
             // set the child process the output same as the parent process.
             
pythonProcessBuilder.redirectOutput(ProcessBuilder.Redirect.INHERIT);
         }
-
         LOG.info(
                 "Starting Python process with environment variables: {{}}, 
command: {}",
-                env.entrySet().stream()
+                ConfigurationUtils.hideSensitiveValues(env).entrySet().stream()
                         .map(e -> e.getKey() + "=" + e.getValue())
                         .collect(Collectors.joining(", ")),
                 String.join(" ", commands));