beliefer commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1992967407
##########
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##########
@@ -470,7 +470,8 @@ public static String[] mergeListsToArray(List<String> base,
List<String> append)
ConfigOptions.key("parallelism.default")
.intType()
.defaultValue(1)
- .withDescription("Default parallelism for jobs.");
+ .withDescription(
+ "Default parallelism for jobs. There are two
special cases. In the first case, when creating a StreamExecutioneEnvironment
without specifying parallelism.default, the number of processors available to
the Java virtual machine will be used. In the second case, when creating mini
cluster without specifying parallelism.default, the total number of slots in
mini cluster will be used.");
Review Comment:
No. The first case only found in the local mode.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
