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

snuyanzin 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 e095557d5db [FLINK-18476][python] 
`PythonEnvUtils#testStartPythonProcess` might fail
e095557d5db is described below

commit e095557d5dbbae33e6011d0b2893af0251f5bb57
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Wed Aug 5 11:42:07 2026 +0200

    [FLINK-18476][python] `PythonEnvUtils#testStartPythonProcess` might fail
---
 .../src/main/java/org/apache/flink/client/python/PythonEnvUtils.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 bd816b6424a..4e4a511430e 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
@@ -383,7 +383,8 @@ final class PythonEnvUtils {
                         .collect(Collectors.joining(", ")),
                 String.join(" ", commands));
         Process process = pythonProcessBuilder.start();
-        if (!process.isAlive()) {
+        // Only a non-zero exit is a start failure; a fast process may already 
have finished.
+        if (!process.isAlive() && process.exitValue() != 0) {
             throw new RuntimeException("Failed to start Python process. ");
         }
 

Reply via email to