(fluss) branch main updated: [lake/paimon] Support passing Fluss table comment through to the Paimon table (#1999)

[yuxia]

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

yuxia 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 9c815738e [lake/paimon] Support passing Fluss table comment through to 
the Paimon table (#1999)
9c815738e is described below

commit 9c815738e3010812572e29cc788dffe7390bfe58
Author: Liebing <44154062+liebin...@users.noreply.github.com>
AuthorDate: Wed Nov 19 20:32:34 2025 +0800

    [lake/paimon] Support passing Fluss table comment through to the Paimon 
table (#1999)
---
 .../java/org/apache/fluss/lake/paimon/utils/PaimonConversions.java    | 4 ++++
 .../org/apache/fluss/lake/paimon/LakeEnabledTableCreateITCase.java    | 3 +++
 2 files changed, 7 insertions(+)

diff --git 
a/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/utils/PaimonConversions.java
 
b/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/utils/PaimonConversions.java
index 03f9ae753..8d561957a 100644
--- 
a/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/utils/PaimonConversions.java
+++ 
b/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/utils/PaimonConversions.java
@@ -203,6 +203,10 @@ public class PaimonConversions {
                 .getCustomProperties()
                 .forEach((k, v) -> setFlussPropertyToPaimon(k, v, options));
         schemaBuilder.options(options.toMap());
+
+        // set comment
+        tableDescriptor.getComment().ifPresent(schemaBuilder::comment);
+
         return schemaBuilder.build();
     }
 
diff --git 
a/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/LakeEnabledTableCreateITCase.java
 
b/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/LakeEnabledTableCreateITCase.java
index 9e28ce7d4..319ebd563 100644
--- 
a/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/LakeEnabledTableCreateITCase.java
+++ 
b/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/LakeEnabledTableCreateITCase.java
@@ -151,6 +151,7 @@ class LakeEnabledTableCreateITCase {
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED, true)
                         .customProperties(customProperties)
                         .distributedBy(BUCKET_NUM, "log_c1", "log_c2")
+                        .comment("test comment")
                         .build();
         TablePath logTablePath = TablePath.of(DATABASE, "log_table");
         admin.createTable(logTablePath, logTable, false).get();
@@ -902,6 +903,8 @@ class LakeEnabledTableCreateITCase {
         // now, check schema
         RowType paimonRowType = paimonTable.rowType();
         assertThat(paimonRowType).isEqualTo(expectedRowType);
+
+        assertThat(paimonTable.comment()).isEqualTo(flussTable.getComment());
     }
 
     private TableDescriptor createTableDescriptor(