[FLINK-23868][Client] JobExecutionResult printed event if suppressSysout is enabled

link3280 · web-flow · commit 7f9587c72305 · 2021-08-22T22:18:32.000+08:00
This closes apache#16891 .
diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java b/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java
@@ -115,7 +115,9 @@ private JobExecutionResult getJobExecutionResult(final JobClient jobClient) thro
             }
 
             jobExecutionResult = jobExecutionResultFuture.get();
-            System.out.println(jobExecutionResult);
+            if (!suppressSysout) {
+                System.out.println(jobExecutionResult);
+            }
         } else {
             jobExecutionResult = new DetachedJobExecutionResult(jobClient.getJobID());
         }
diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java b/flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java
@@ -121,7 +121,9 @@ private JobExecutionResult getJobExecutionResult(final JobClient jobClient) thro
             }
 
             jobExecutionResult = jobExecutionResultFuture.get();
-            System.out.println(jobExecutionResult);
+            if (!suppressSysout) {
+                System.out.println(jobExecutionResult);
+            }
         } else {
             jobExecutionResult = new DetachedJobExecutionResult(jobClient.getJobID());
         }

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,9 @@ private JobExecutionResult getJobExecutionResult(final JobClient jobClient) thro`
`115`	`115`	`}`
`116`	`116`
`117`	`117`	`jobExecutionResult = jobExecutionResultFuture.get();`
`118`		`- System.out.println(jobExecutionResult);`
	`118`	`+ if (!suppressSysout) {`
	`119`	`+ System.out.println(jobExecutionResult);`
	`120`	`+ }`
`119`	`121`	`} else {`
`120`	`122`	`jobExecutionResult = new DetachedJobExecutionResult(jobClient.getJobID());`
`121`	`123`	`}`
Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,9 @@ private JobExecutionResult getJobExecutionResult(final JobClient jobClient) thro`
`121`	`121`	`}`
`122`	`122`
`123`	`123`	`jobExecutionResult = jobExecutionResultFuture.get();`
`124`		`- System.out.println(jobExecutionResult);`
	`124`	`+ if (!suppressSysout) {`
	`125`	`+ System.out.println(jobExecutionResult);`
	`126`	`+ }`
`125`	`127`	`} else {`
`126`	`128`	`jobExecutionResult = new DetachedJobExecutionResult(jobClient.getJobID());`
`127`	`129`	`}`