Flink: SortKeySerializer and CompletedStatisticsSerializer support ve…

…rsion，and add UT for the change
apache · Dec 4, 2024 · c412954 · c412954
1 parent a2d4e04
commit c412954
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
@@ -123,5 +123,6 @@ boolean isValid() {
       }
     }
     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
@@ -81,6 +81,7 @@ static CompletedStatistics deserializeCompletedStatistics(
         throw new RuntimeException("Fail to deserialize aggregated statistics,change to v1");
       }
       return completedStatistics;
+
     } catch (Exception e) {
       try {
         statisticsSerializer.changeSortKeySerializerVersion(1);
-Original file line number
+Diff line change
@@ Expand Up / @@ -123,5 +123,6 @@ boolean isValid() { @@
           }
         }
         return true;
       }
     }