File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -285,7 +285,7 @@ public int getTotalNumberOfMemorySegments() {
285285 }
286286
287287 public long getTotalMemory () {
288- return getTotalNumberOfMemorySegments () * memorySegmentSize ;
288+ return ( long ) getTotalNumberOfMemorySegments () * memorySegmentSize ;
289289 }
290290
291291 public int getNumberOfAvailableMemorySegments () {
@@ -295,15 +295,15 @@ public int getNumberOfAvailableMemorySegments() {
295295 }
296296
297297 public long getAvailableMemory () {
298- return getNumberOfAvailableMemorySegments () * memorySegmentSize ;
298+ return ( long ) getNumberOfAvailableMemorySegments () * memorySegmentSize ;
299299 }
300300
301301 public int getNumberOfUsedMemorySegments () {
302302 return getTotalNumberOfMemorySegments () - getNumberOfAvailableMemorySegments ();
303303 }
304304
305305 public long getUsedMemory () {
306- return getNumberOfUsedMemorySegments () * memorySegmentSize ;
306+ return ( long ) getNumberOfUsedMemorySegments () * memorySegmentSize ;
307307 }
308308
309309 public int getNumberOfRegisteredBufferPools () {
You can’t perform that action at this time.
0 commit comments