[hotfix] Fix checkstyle in JobVertex and DefaultExecutionGraphConstructionTest
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java
index deeb9a2..a3dc3b5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java
@@ -68,7 +68,7 @@
* C E
* </pre>
*
- * This is the same order that operators are stored in the {@code StreamTask}.
+ * <p>This is the same order that operators are stored in the {@code StreamTask}.
*/
private final List<OperatorIDPair> operatorIDs;
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphConstructionTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphConstructionTest.java
index bebbef4..59f9488 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphConstructionTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphConstructionTest.java
@@ -101,7 +101,7 @@
}
/**
- * Creates a JobGraph of the following form:
+ * Creates a JobGraph of the following form.
*
* <pre>
* v1--->v2-->\
@@ -178,10 +178,8 @@
// create results for v2 and v3
IntermediateDataSet v2result = v2.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
- IntermediateDataSet v3result_1 =
- v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
- IntermediateDataSet v3result_2 =
- v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
+ IntermediateDataSet v3Result1 = v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
+ IntermediateDataSet v3Result2 = v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
JobVertex v4 = new JobVertex("vertex4");
JobVertex v5 = new JobVertex("vertex5");
@@ -192,10 +190,10 @@
v5.setInvokableClass(AbstractInvokable.class);
v4.connectDataSetAsInput(v2result, DistributionPattern.ALL_TO_ALL);
- v4.connectDataSetAsInput(v3result_1, DistributionPattern.ALL_TO_ALL);
+ v4.connectDataSetAsInput(v3Result1, DistributionPattern.ALL_TO_ALL);
v5.connectNewDataSetAsInput(
v4, DistributionPattern.ALL_TO_ALL, ResultPartitionType.PIPELINED);
- v5.connectDataSetAsInput(v3result_2, DistributionPattern.ALL_TO_ALL);
+ v5.connectDataSetAsInput(v3Result2, DistributionPattern.ALL_TO_ALL);
List<JobVertex> ordered = Arrays.asList(v1, v2, v3);
@@ -246,10 +244,8 @@
// create results for v2 and v3
IntermediateDataSet v2result = v2.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
- IntermediateDataSet v3result_1 =
- v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
- IntermediateDataSet v3result_2 =
- v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
+ IntermediateDataSet v3result1 = v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
+ IntermediateDataSet v3result2 = v3.createAndAddResultDataSet(ResultPartitionType.PIPELINED);
// construct part two of the execution graph
JobVertex v4 = new JobVertex("vertex4");
@@ -261,10 +257,10 @@
v5.setInvokableClass(AbstractInvokable.class);
v4.connectIdInput(v2result.getId(), DistributionPattern.ALL_TO_ALL);
- v4.connectIdInput(v3result_1.getId(), DistributionPattern.ALL_TO_ALL);
+ v4.connectIdInput(v3result1.getId(), DistributionPattern.ALL_TO_ALL);
v5.connectNewDataSetAsInput(
v4, DistributionPattern.ALL_TO_ALL, ResultPartitionType.PIPELINED);
- v5.connectIdInput(v3result_2.getId(), DistributionPattern.ALL_TO_ALL);
+ v5.connectIdInput(v3result2.getId(), DistributionPattern.ALL_TO_ALL);
List<JobVertex> ordered = Arrays.asList(v1, v2, v3);
List<JobVertex> ordered2 = Arrays.asList(v4, v5);
