1515package com .starrocks .catalog ;
1616
1717import com .google .common .base .Joiner ;
18+ import com .google .common .base .Strings ;
1819import com .starrocks .analysis .DescriptorTable ;
1920import com .starrocks .common .util .TimeUtils ;
2021import com .starrocks .planner .PaimonScanNode ;
2324import com .starrocks .thrift .TPaimonTable ;
2425import com .starrocks .thrift .TTableDescriptor ;
2526import com .starrocks .thrift .TTableType ;
26- import org .apache .paimon .catalog .Identifier ;
2727import org .apache .paimon .table .DataTable ;
2828import org .apache .paimon .types .DataField ;
2929
@@ -41,6 +41,7 @@ public class PaimonTable extends Table {
4141 private String databaseName ;
4242 private String tableName ;
4343 private org .apache .paimon .table .Table paimonNativeTable ;
44+ private String uuid ;
4445 private List <String > partColumnNames ;
4546 private List <String > paimonFieldNames ;
4647 private Map <String , String > properties ;
@@ -88,11 +89,11 @@ public void setPaimonNativeTable(org.apache.paimon.table.Table paimonNativeTable
8889
8990 @ Override
9091 public String getUUID () {
91- if (!new Identifier (databaseName , tableName ).isSystemTable ()) {
92- return String .join ("." , catalogName , paimonNativeTable .uuid ());
93- } else {
94- return String .join ("." , catalogName , databaseName , tableName , paimonNativeTable .uuid ());
92+ if (Strings .isNullOrEmpty (this .uuid )) {
93+ this .uuid = String .join ("." , catalogName , databaseName , tableName ,
94+ paimonNativeTable .uuid ().replace ("." , "_" ));
9595 }
96+ return this .uuid ;
9697 }
9798
9899 @ Override
0 commit comments