Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5879#discussion_r191764153
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java ---
@@ -304,7 +305,8 @@ public int getMaxParallelism() {
/**
* Sets the maximum parallelism for the task.
*
- * @param maxParallelism The maximum parallelism to be set. must be
between 1 and Short.MAX_VALUE.
+ * @param maxParallelism The maximum parallelism to be set.
+ * Must be between 1 and {@link
KeyGroupRangeAssignment#UPPER_BOUND_MAX_PARALLELISM}.
--- End diff --
Unrelated change. Will remove while merging, if you are ok with it
@sihuazhou .
---
