This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5f5cdeb782ef2596d900de5b90ff2cc7bb62e735 Author: Stephan Ewen <[email protected]> AuthorDate: Fri Nov 15 20:24:39 2019 +0100 [hotfix][runtime] Checkstyle fixes in JobVertex --- .../src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 e8c7528..79b6dd3 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 @@ -62,10 +62,10 @@ public class JobVertex implements java.io.Serializable { private final ArrayList<OperatorID> operatorIdsAlternatives = new ArrayList<>(); /** List of produced data sets, one per writer. */ - private final ArrayList<IntermediateDataSet> results = new ArrayList<IntermediateDataSet>(); + private final ArrayList<IntermediateDataSet> results = new ArrayList<>(); /** List of edges with incoming data. One per Reader. */ - private final ArrayList<JobEdge> inputs = new ArrayList<JobEdge>(); + private final ArrayList<JobEdge> inputs = new ArrayList<>(); /** Number of subtasks to split this task into at runtime. */ private int parallelism = ExecutionConfig.PARALLELISM_DEFAULT;
