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 8fd462a13 [hotfix] Hide root in IcebergPathFactory
8fd462a13 is described below
commit 8fd462a1336d9a379c5880d425c4972cc1b95c7d
Author: Jingsong <[email protected]>
AuthorDate: Fri Jul 12 10:41:10 2024 +0800
[hotfix] Hide root in IcebergPathFactory
---
.../src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java | 6 +++---
.../java/org/apache/paimon/iceberg/IcebergCompatibilityTest.java | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java
b/paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java
index 8b5680952..82f9f02ef 100644
---
a/paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java
+++
b/paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java
@@ -26,19 +26,19 @@ import java.util.UUID;
/** Path factory for Iceberg metadata files. */
public class IcebergPathFactory {
- private final Path root;
+ private final Path metadataDirectory;
private final String uuid;
private int manifestFileCount;
private int manifestListCount;
public IcebergPathFactory(Path root) {
- this.root = root;
+ this.metadataDirectory = new Path(root, "metadata");
this.uuid = UUID.randomUUID().toString();
}
public Path metadataDirectory() {
- return new Path(root, "metadata");
+ return metadataDirectory;
}
public Path newManifestFile() {
diff --git
a/paimon-core/src/test/java/org/apache/paimon/iceberg/IcebergCompatibilityTest.java
b/paimon-core/src/test/java/org/apache/paimon/iceberg/IcebergCompatibilityTest.java
index 25700705d..e653142a8 100644
---
a/paimon-core/src/test/java/org/apache/paimon/iceberg/IcebergCompatibilityTest.java
+++
b/paimon-core/src/test/java/org/apache/paimon/iceberg/IcebergCompatibilityTest.java
@@ -68,7 +68,7 @@ public class IcebergCompatibilityTest {
@TempDir java.nio.file.Path tempDir;
@Test
- public void testUnpartitionedPrimaryKeyTable() throws Exception {
+ public void testUnartitionedPrimaryKeyTable() throws Exception {
RowType rowType =
RowType.of(
new DataType[] {