[hotfix] Minor StreamGraphGenerator refactoring

wbo4958 · Oct 1, 2020 · 4fcd7d3 · 4fcd7d3
1 parent c2e3399
commit 4fcd7d3
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...reaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java b/...reaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
@@ -140,7 +140,10 @@ public static int getNewIterationNodeId() {
 	// we have loops, i.e. feedback edges.
 	private Map<Transformation<?>, Collection<Integer>> alreadyTransformed;
 
-	public StreamGraphGenerator(List<Transformation<?>> transformations, ExecutionConfig executionConfig, CheckpointConfig checkpointConfig) {
+	public StreamGraphGenerator(
+			final List<Transformation<?>> transformations,
+			final ExecutionConfig executionConfig,
+			final CheckpointConfig checkpointConfig) {
 		this.transformations = checkNotNull(transformations);
 		this.executionConfig = checkNotNull(executionConfig);
 		this.checkpointConfig = checkNotNull(checkpointConfig);