From 5f3b2c7d805b6040d538c08f09f11e8db0331af5 Mon Sep 17 00:00:00 2001 From: sunxiaojian Date: Thu, 7 Mar 2024 18:43:21 +0800 Subject: [PATCH] optimized code --- paimon-core/src/main/java/org/apache/paimon/table/Table.java | 2 +- .../src/main/java/org/apache/paimon/utils/BranchManager.java | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/table/Table.java b/paimon-core/src/main/java/org/apache/paimon/table/Table.java index 01a044584b8b..bf3baa88df39 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/Table.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/Table.java @@ -92,7 +92,7 @@ public interface Table extends Serializable { @Experimental void createBranch(String branchName); - /** Create a branch from given tag. */ + /** Create a branch from given snapshot. */ @Experimental void createBranch(String branchName, long snapshotId); diff --git a/paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java b/paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java index c1ecbab583eb..a3511dc2678d 100644 --- a/paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java +++ b/paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java @@ -98,7 +98,10 @@ public void createBranch(String branchName) { "Branch name cannot be pure numeric string but is '%s'.", branchName); try { - fileIO.mkdirs(branchPath(branchName)); + TableSchema latestSchema = schemaManager.latest().get(); + fileIO.copyFileUtf8( + schemaManager.toSchemaPath(latestSchema.id()), + schemaManager.branchSchemaPath(branchName, latestSchema.id())); } catch (IOException e) { throw new RuntimeException( String.format(