[core] FilesTable file_path col should be the path instead of name (#…

…4503)
apache · Nov 12, 2024 · 4d32ed8 · 4d32ed8
1 parent 60f6611
commit 4d32ed8
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java b/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java
@@ -385,7 +385,9 @@ private LazyGenericRow toRow(
                                                         partitionConverter.convert(
                                                                 dataSplit.partition()))),
                         dataSplit::bucket,
-                        () -> BinaryString.fromString(dataFileMeta.fileName()),
+                        () ->
+                                BinaryString.fromString(
+                                        dataSplit.bucketPath() + "/" + dataFileMeta.fileName()),
                         () ->
                                 BinaryString.fromString(
                                         DataFilePathFactory.formatIdentifier(

diff --git a/paimon-core/src/test/java/org/apache/paimon/table/system/FilesTableTest.java b/paimon-core/src/test/java/org/apache/paimon/table/system/FilesTableTest.java
@@ -191,7 +191,16 @@ private List<InternalRow> getExpectedResult(long snapshotId) {
                             BinaryString.fromString(
                                     Arrays.toString(new String[] {partition1, partition2})),
                             fileEntry.bucket(),
-                            BinaryString.fromString(file.fileName()),
+                            BinaryString.fromString(
+                                    table.location()
+                                            + "/pt1="
+                                            + partition1
+                                            + "/pt2="
+                                            + partition2
+                                            + "/bucket-"
+                                            + fileEntry.bucket()
+                                            + "/"
+                                            + file.fileName()),
                             BinaryString.fromString(file.fileFormat()),
                             file.schemaId(),
                             file.level(),