[hotfix][network] Removed unused method in LocalInputChannel

weichunshen89 · Jun 7, 2021 · aca5d81 · aca5d81
1 parent 11301c2
commit aca5d81
Showing 1 changed file with 0 additions and 22 deletions.
diff --git a/...c/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java b/...c/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
@@ -72,28 +72,6 @@ public class LocalInputChannel extends InputChannel implements BufferAvailabilit
 
     private final ChannelStatePersister channelStatePersister;
 
-    public LocalInputChannel(
-            SingleInputGate inputGate,
-            int channelIndex,
-            ResultPartitionID partitionId,
-            ResultPartitionManager partitionManager,
-            TaskEventPublisher taskEventPublisher,
-            Counter numBytesIn,
-            Counter numBuffersIn) {
-
-        this(
-                inputGate,
-                channelIndex,
-                partitionId,
-                partitionManager,
-                taskEventPublisher,
-                0,
-                0,
-                numBytesIn,
-                numBuffersIn,
-                ChannelStateWriter.NO_OP);
-    }
-
     public LocalInputChannel(
             SingleInputGate inputGate,
             int channelIndex,