Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3182#discussion_r97337263
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
---
@@ -57,47 +57,51 @@
/** Use the same log for all ExecutionGraph classes */
private static final Logger LOG = ExecutionGraph.LOG;
-
- private final SerializableObject stateMonitor = new
SerializableObject();
+
+ public static final int VALUE_NOT_SET = -1;
+
+ private final Object stateMonitor = new Object();
private final ExecutionGraph graph;
private final JobVertex jobVertex;
private final ExecutionVertex[] taskVertices;
- private IntermediateResult[] producedDataSets;
+ private final IntermediateResult[] producedDataSets;
private final List<IntermediateResult> inputs;
private final int parallelism;
- private final int maxParallelism;
-
private final boolean[] finishedSubtasks;
-
- private volatile int numSubtasksInFinalState;
-
+
private final SlotSharingGroup slotSharingGroup;
-
+
private final CoLocationGroup coLocationGroup;
-
+
private final InputSplit[] inputSplits;
+ private final int maxParallelismConfigured;
+
+ private int maxParallelismDerived;
+
+ private volatile int numSubtasksInFinalState;
+
/**
* Serialized task information which is for all sub tasks the same.
Thus, it avoids to
* serialize the same information multiple times in order to create the
* TaskDeploymentDescriptors.
*/
- private final SerializedValue<TaskInformation>
serializedTaskInformation;
+ private SerializedValue<TaskInformation> serializedTaskInformation;
private InputSplitAssigner splitAssigner;
public ExecutionJobVertex(
ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
- Time timeout) throws JobException, IOException {
+ Time timeout) throws JobException {
--- End diff --
You are right, but I kept the indentation to avoid formatting changes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
