diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java index a1ee77489d8e6138fe7580a853d47d5e1582eefb..4b548d343c1d53736d8f1682cb0deae8cc33ef30 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java @@ -87,7 +87,7 @@ public class NettyShuffleEnvironment implements ShuffleEnvironment(); + this.inputGatesById = new ConcurrentHashMap<>(10); this.resultPartitionFactory = resultPartitionFactory; this.singleInputGateFactory = singleInputGateFactory; this.isClosed = false; @@ -126,11 +126,11 @@ public class NettyShuffleEnvironment implements ShuffleEnvironment local channelStatistics.numLocalChannels++; return new LocalInputChannel( @@ -241,9 +241,9 @@ public class SingleInputGateFactory { } private static class ChannelStatistics { - int numLocalChannels = 0; - int numRemoteChannels = 0; - int numUnknownChannels = 0; + int numLocalChannels; + int numRemoteChannels; + int numUnknownChannels; @Override public String toString() {