(paimon-webui) branch main updated: [Bugfix] Fix displaying snapshots of Paimon tables (#242)

[nicholasjiang]

This is an automated email from the ASF dual-hosted git repository.

nicholasjiang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/paimon-webui.git


The following commit(s) were added to refs/heads/main by this push:
     new f8a0296e [Bugfix] Fix displaying snapshots of Paimon tables (#242)
f8a0296e is described below

commit f8a0296e6918c0de13ee65e660379035df3831b0
Author: yangyang zhong <35210666+hdyg...@users.noreply.github.com>
AuthorDate: Tue May 28 14:02:34 2024 +0800

    [Bugfix] Fix displaying snapshots of Paimon tables (#242)
---
 .../main/java/org/apache/paimon/web/server/data/vo/SnapshotVO.java  | 4 ----
 .../apache/paimon/web/server/service/impl/MetadataServiceImpl.java  | 6 ++----
 .../apache/paimon/web/server/controller/MetadataControllerTest.java | 2 --
 3 files changed, 2 insertions(+), 10 deletions(-)

diff --git 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/data/vo/SnapshotVO.java
 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/data/vo/SnapshotVO.java
index 38d2ff16..7087df11 100644
--- 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/data/vo/SnapshotVO.java
+++ 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/data/vo/SnapshotVO.java
@@ -56,9 +56,5 @@ public class SnapshotVO {
 
     private Long changelogRecordCount;
 
-    private Integer addedFileCount;
-
-    private Integer deletedFileCount;
-
     private Long watermark;
 }
diff --git 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/service/impl/MetadataServiceImpl.java
 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/service/impl/MetadataServiceImpl.java
index 96773388..8cfee903 100644
--- 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/service/impl/MetadataServiceImpl.java
+++ 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/service/impl/MetadataServiceImpl.java
@@ -120,9 +120,7 @@ public class MetadataServiceImpl implements MetadataService 
{
                                         
.totalRecordCount(internalRow.getLong(9))
                                         
.deltaRecordCount(internalRow.getLong(10))
                                         
.changelogRecordCount(internalRow.getLong(11))
-                                        .addedFileCount(internalRow.getInt(12))
-                                        
.deletedFileCount(internalRow.getInt(13))
-                                        .watermark(getSafeLong(internalRow, 
14))
+                                        .watermark(getSafeLong(internalRow, 
12))
                                         .build();
                         result.add(build);
                     });
@@ -258,7 +256,7 @@ public class MetadataServiceImpl implements MetadataService 
{
     }
 
     private Long getSafeLong(InternalRow internalRow, int index) {
-        return internalRow.isNullAt(index) ? null : internalRow.getLong(14);
+        return internalRow.isNullAt(index) ? null : internalRow.getLong(index);
     }
 
     private LocalDateTime getSafeLocalDateTime(InternalRow internalRow, int 
index) {
diff --git 
a/paimon-web-server/src/test/java/org/apache/paimon/web/server/controller/MetadataControllerTest.java
 
b/paimon-web-server/src/test/java/org/apache/paimon/web/server/controller/MetadataControllerTest.java
index dc0a8137..f099a9bd 100644
--- 
a/paimon-web-server/src/test/java/org/apache/paimon/web/server/controller/MetadataControllerTest.java
+++ 
b/paimon-web-server/src/test/java/org/apache/paimon/web/server/controller/MetadataControllerTest.java
@@ -478,8 +478,6 @@ public class MetadataControllerTest extends 
ControllerTestBase {
         assertEquals(3, snapshotVO.getTotalRecordCount());
         assertEquals(3, snapshotVO.getDeltaRecordCount());
         assertEquals(0, snapshotVO.getChangelogRecordCount());
-        assertEquals(3, snapshotVO.getAddedFileCount());
-        assertEquals(0, snapshotVO.getDeletedFileCount());
         assertNull(snapshotVO.getWatermark());
     }