From 73719109748587a112b91822b61110891fb2ebbc Mon Sep 17 00:00:00 2001
From: sharkdtu <sharkdtu@tencent.com>
Date: Wed, 21 Apr 2021 11:55:38 +0800
Subject: [PATCH] [BP-1.13][FLINK-22385][runtime] Fixes type cast error

---
 .../flink/runtime/io/network/buffer/NetworkBufferPool.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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() {