[FLINK-17805][hotfix][network] Fix/update/rename InputProcessorUtil.c…

…reateCheckpointedInputGatePair method
zhengcanbin · May 21, 2020 · 2efa2ed · 2efa2ed
1 parent 303e008
commit 2efa2ed
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...treaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java b/...treaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java
@@ -66,7 +66,7 @@ public static CheckpointedInputGate createCheckpointedInputGate(
 	 * @return a pair of {@link CheckpointedInputGate} created for two corresponding
 	 * {@link InputGate}s supplied as parameters.
 	 */
-	public static CheckpointedInputGate[] createCheckpointedInputGatePair(
+	public static CheckpointedInputGate[] createCheckpointedMultipleInputGate(
 			AbstractInvokable toNotifyOnCheckpoint,
 			StreamConfig config,
 			ChannelStateWriter channelStateWriter,

diff --git a/...-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java b/...-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java
@@ -91,7 +91,7 @@ protected void createInputProcessor(
 			headOperator instanceof InputSelectable ? (InputSelectable) headOperator : null,
 			inputGates.length);
 
-		CheckpointedInputGate[] checkpointedInputGates = InputProcessorUtil.createCheckpointedInputGatePair(
+		CheckpointedInputGate[] checkpointedInputGates = InputProcessorUtil.createCheckpointedMultipleInputGate(
 			this,
 			getConfiguration(),
 			getChannelStateWriter(),

diff --git a/...aming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java b/...aming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
@@ -54,7 +54,7 @@ protected void createInputProcessor(
 			headOperator instanceof InputSelectable ? (InputSelectable) headOperator : null);
 
 		// create an input instance for each input
-		CheckpointedInputGate[] checkpointedInputGates = InputProcessorUtil.createCheckpointedInputGatePair(
+		CheckpointedInputGate[] checkpointedInputGates = InputProcessorUtil.createCheckpointedMultipleInputGate(
 			this,
 			getConfiguration(),
 			getChannelStateWriter(),