[
https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188965#comment-15188965
]
ASF GitHub Bot commented on FLINK-3589:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1778#discussion_r55653990
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -64,10 +64,15 @@
/**
* The constant to use for the parallelism, if the system should use
the number
- * of currently available slots.
+ * of currently available slots.
*/
public static final int PARALLELISM_AUTO_MAX = Integer.MAX_VALUE;
+ /**
+ * The flag value indicating an unknown or unset parallelism.
+ */
+ public static final int PARALLELISM_UNKNOWN = -1;
--- End diff --
i would prefer calling it parallelism_default.
> Allow setting Operator parallelism to default value
> ---------------------------------------------------
>
> Key: FLINK-3589
> URL: https://issues.apache.org/jira/browse/FLINK-3589
> Project: Flink
> Issue Type: Improvement
> Components: Java API
> Affects Versions: 1.1.0
> Reporter: Greg Hogan
> Assignee: Greg Hogan
> Priority: Minor
>
> User's can override the parallelism for a single operator by calling
> {{Operator.setParallelism}}, which accepts a positive value. {{Operator}}
> uses {{-1}} to indicate default parallelism. It would be nice to name and
> accept this default value.
> This would enable user algorithms to allow configurable parallelism while
> still chaining operator methods.
> For example, currently:
> {code}
> private int parallelism;
> ...
> public void setParallelism(int parallelism) {
> this.parallelism = parallelism;
> }
> ...
> MapOperator<Edge<K,LongValue>, Edge<K,IntValue>> newEdges =
> edges
> .map(new MyMapFunction<K>())
> .name("My map function");
> if (parallelism > 0) {
> newEdges.setParallelism(parallelism);
> }
> {code}
> Could be simplified to:
> {code}
> private int parallelism = Operator.DEFAULT_PARALLELISM;
> ...
> public void setParallelism(int parallelism) {
> this.parallelism = parallelism;
> }
> ...
> DataSet<Edge<K,IntValue>> newEdges = edges
> .map(new MyMapFunction<K>())
> .setParallelism(parallelism)
> .name("My map function");
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
