diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java index 6936b7bee0c56..4f506349eb167 100755 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java @@ -285,7 +285,7 @@ public int getTotalNumberOfMemorySegments() { } public long getTotalMemory() { - return getTotalNumberOfMemorySegments() * memorySegmentSize; + return (long) getTotalNumberOfMemorySegments() * memorySegmentSize; } public int getNumberOfAvailableMemorySegments() { @@ -295,7 +295,7 @@ public int getNumberOfAvailableMemorySegments() { } public long getAvailableMemory() { - return getNumberOfAvailableMemorySegments() * memorySegmentSize; + return (long) getNumberOfAvailableMemorySegments() * memorySegmentSize; } public int getNumberOfUsedMemorySegments() { @@ -303,7 +303,7 @@ public int getNumberOfUsedMemorySegments() { } public long getUsedMemory() { - return getNumberOfUsedMemorySegments() * memorySegmentSize; + return (long) getNumberOfUsedMemorySegments() * memorySegmentSize; } public int getNumberOfRegisteredBufferPools() {