From c4129542ad915682b03d27691a350d0736721306 Mon Sep 17 00:00:00 2001
From: Guosmilesmile <511955993@qq.com>
Date: Thu, 5 Dec 2024 01:53:54 +0800
Subject: [PATCH] =?UTF-8?q?Flink:=20SortKeySerializer=20and=20CompletedSta?=
 =?UTF-8?q?tisticsSerializer=20support=20version=EF=BC=8Cand=20add=20UT=20?=
 =?UTF-8?q?for=20the=20change?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../apache/iceberg/flink/sink/shuffle/CompletedStatistics.java   | 1 +
 .../org/apache/iceberg/flink/sink/shuffle/StatisticsUtil.java    | 1 +
 2 files changed, 2 insertions(+)

diff --git a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java
index 0363bbfbf597..09f0023cb4ba 100644
--- a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/CompletedStatistics.java
+++ b/flink/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
index 47a9e5af28c2..2c77badab23a 100644
--- 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);