Flink: SortKeySerializer and CompletedStatisticsSerializer support ve…

…rsion，and add UT for the change
apache · Dec 4, 2024 · fb226bb · fb226bb
1 parent a2d4e04
commit fb226bb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/.../v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java b/.../v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java
@@ -122,6 +122,7 @@ boolean isValid() {
         return false;
       }
     }
+
     return true;
   }
 }
diff --git a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java
@@ -80,6 +80,7 @@ static CompletedStatistics deserializeCompletedStatistics(
       if (!completedStatistics.isValid()) {
         throw new RuntimeException("Fail to deserialize aggregated statistics,change to v1");
       }
+
       return completedStatistics;
     } catch (Exception e) {
       try {
-Original file line number
+Diff line change
@@ Expand Up / @@ -122,6 +122,7 @@ boolean isValid() { @@
             return false;
           }
         }
         return true;
       }
     }