[FLINK-37438][refactor] Improve the createLocalEnvironment by reduce duplicate operation on Configuration (#26273)

beliefer · web-flow · commit 452b648495f2 · 2025-03-17T14:47:41.000+08:00
diff --git a/flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -2218,7 +2218,8 @@ public static LocalStreamEnvironment createLocalEnvironment() {
      * @return A local execution environment with the specified parallelism.
      */
     public static LocalStreamEnvironment createLocalEnvironment(int parallelism) {
-        return createLocalEnvironment(parallelism, new Configuration());
+        return createLocalEnvironment(
+                new Configuration().set(CoreOptions.DEFAULT_PARALLELISM, parallelism));
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -2218,7 +2218,8 @@ public static LocalStreamEnvironment createLocalEnvironment() {`
`2218`	`2218`	`* @return A local execution environment with the specified parallelism.`
`2219`	`2219`	`*/`
`2220`	`2220`	`public static LocalStreamEnvironment createLocalEnvironment(int parallelism) {`
`2221`		`- return createLocalEnvironment(parallelism, new Configuration());`
	`2221`	`+ return createLocalEnvironment(`
	`2222`	`+ new Configuration().set(CoreOptions.DEFAULT_PARALLELISM, parallelism));`
`2222`	`2223`	`}`
`2223`	`2224`
`2224`	`2225`	`/**`