We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e3456e3 commit ffad337Copy full SHA for ffad337
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java
@@ -317,8 +317,8 @@ private ExecutionGraphWithVertexParallelism(
317
}
318
319
public static ExecutionGraphWithVertexParallelism create(
320
- ExecutionGraph executionGraph, JobSchedulingPlan vertexParallelism) {
321
- return new ExecutionGraphWithVertexParallelism(executionGraph, vertexParallelism);
+ ExecutionGraph executionGraph, JobSchedulingPlan jobSchedulingPlan) {
+ return new ExecutionGraphWithVertexParallelism(executionGraph, jobSchedulingPlan);
322
323
324
public ExecutionGraph getExecutionGraph() {
0 commit comments