Github user dawidwys commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5448#discussion_r197707411
  
    --- Diff: 
flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java ---
    @@ -95,8 +95,8 @@ public long getKibiBytes() {
        /**
         * Gets the memory size in Mebibytes (= 1024 Kibibytes).
         */
    -   public long getMebiBytes() {
    -           return bytes >> 20;
    +   public int getMebiBytes() {
    +           return (int) (bytes >> 20);
    --- End diff --
    
    use `checkedDownCast` here


---

Reply via email to