This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.1 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit 800f5f7f15bd449da96104ee5a22b17753d1d5bd Author: gavin9402 <[email protected]> AuthorDate: Sun Apr 27 12:44:01 2025 +0800 [core] Fix reporting PartitionStatistics params construct bug (#5528) --- .../java/org/apache/paimon/utils/PartitionStatisticsReporter.java | 2 +- .../org/apache/paimon/utils/PartitionStatisticsReporterTest.java | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java b/paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java index bd8bef8996..8b045c4800 100644 --- a/paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java +++ b/paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java @@ -84,7 +84,7 @@ public class PartitionStatisticsReporter implements Closeable { PartitionStatistics partitionStats = new PartitionStatistics( - partitionSpec, fileCount, totalSize, rowCount, modifyTimeMillis); + partitionSpec, rowCount, totalSize, fileCount, modifyTimeMillis); LOG.info("alter partition {} with statistic {}.", partitionSpec, partitionStats); partitionHandler.alterPartitions(Collections.singletonList(partitionStats)); } diff --git a/paimon-core/src/test/java/org/apache/paimon/utils/PartitionStatisticsReporterTest.java b/paimon-core/src/test/java/org/apache/paimon/utils/PartitionStatisticsReporterTest.java index ecc20dc686..adcf1ac1d7 100644 --- a/paimon-core/src/test/java/org/apache/paimon/utils/PartitionStatisticsReporterTest.java +++ b/paimon-core/src/test/java/org/apache/paimon/utils/PartitionStatisticsReporterTest.java @@ -74,6 +74,11 @@ public class PartitionStatisticsReporterTest { BinaryString.fromString("a"), BinaryString.fromString("a"), BinaryString.fromString("a"))); + writer.write( + GenericRow.of( + BinaryString.fromString("a"), + BinaryString.fromString("c"), + BinaryString.fromString("c"))); writer.write( GenericRow.of( BinaryString.fromString("b"), @@ -128,7 +133,7 @@ public class PartitionStatisticsReporterTest { Assertions.assertThat(partitionParams).containsKey("c1=a/"); Assertions.assertThat(partitionParams.get("c1=a/").toString()) .isEqualTo( - "{spec={c1=a}, recordCount=1, fileSizeInBytes=591, fileCount=1, lastFileCreationTime=1729598544974}"); + "{spec={c1=a}, recordCount=2, fileSizeInBytes=632, fileCount=1, lastFileCreationTime=1729598544974}"); action.close(); Assertions.assertThat(closed).isTrue(); }
