(paimon) branch master updated: [core] FilesTable file_path col should be the path instead of name (#4503)

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 4d32ed8b5 [core] FilesTable file_path col should be the path instead 
of name (#4503)
4d32ed8b5 is described below

commit 4d32ed8b558d13ead30df74efe1941704c822bd8
Author: wangwj <hongli....@gmail.com>
AuthorDate: Tue Nov 12 22:23:44 2024 +0800

    [core] FilesTable file_path col should be the path instead of name (#4503)
---
 .../main/java/org/apache/paimon/table/system/FilesTable.java  |  4 +++-
 .../java/org/apache/paimon/table/system/FilesTableTest.java   | 11 ++++++++++-
 2 files changed, 13 insertions(+), 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
index 53d207812..0232fc2d2 100644
--- 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 @@ public class FilesTable implements ReadonlyTable {
                                                         
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
index 1a692270a..f0280560c 100644
--- 
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 @@ public class FilesTableTest extends TableTestBase {
                             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(),