(fluss) branch main updated: [hotfix] Use CatalogTableAdapter rather than CatalogTable.newBuilder in flink catalog. (#2275)

[hongshun]

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

hongshun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 08c9648b2 [hotfix] Use CatalogTableAdapter rather than 
CatalogTable.newBuilder in flink catalog. (#2275)
08c9648b2 is described below

commit 08c9648b20380a8fc8b258fcc94c74b373de0fe9
Author: Hongshun Wang <125648852+loserwang1...@users.noreply.github.com>
AuthorDate: Mon Dec 29 21:13:40 2025 +0800

    [hotfix] Use CatalogTableAdapter rather than CatalogTable.newBuilder in 
flink catalog. (#2275)
---
 .../java/org/apache/fluss/flink/catalog/FlinkCatalog.java  | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
index 37e9f7c5e..9d0151133 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
@@ -23,6 +23,7 @@ import org.apache.fluss.client.admin.Admin;
 import org.apache.fluss.config.ConfigOptions;
 import org.apache.fluss.config.Configuration;
 import org.apache.fluss.exception.InvalidTableException;
+import org.apache.fluss.flink.adapter.CatalogTableAdapter;
 import org.apache.fluss.flink.lake.LakeFlinkCatalog;
 import org.apache.fluss.flink.procedure.ProcedureManager;
 import org.apache.fluss.flink.utils.CatalogExceptionUtils;
@@ -842,14 +843,11 @@ public class FlinkCatalog extends AbstractCatalog {
         if (!indexKeys.isEmpty()) {
             indexes.add(indexKeys);
         }
-        return CatalogTable.newBuilder()
-                .schema(withIndex(table.getUnresolvedSchema(), indexes))
-                .comment(table.getComment())
-                .partitionKeys(table.getPartitionKeys())
-                .options(table.getOptions())
-                .snapshot(table.getSnapshot().orElse(null))
-                .distribution(table.getDistribution().orElse(null))
-                .build();
+        return CatalogTableAdapter.toCatalogTable(
+                withIndex(table.getUnresolvedSchema(), indexes),
+                table.getComment(),
+                table.getPartitionKeys(),
+                table.getOptions());
     }
 
     private static boolean isPrefixList(List<String> fullList, List<String> 
prefixList) {