(doris) 01/02: branch-3.0: [fix](paimon) avoid get paimon table when replay

[morningman]

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

morningman pushed a commit to branch branch-3.0.4
in repository https://gitbox.apache.org/repos/asf/doris.git
commit e9f4e11df0e78dd2e37a4f1e78fbad5fcc6ebd75
Author: morningman <yun...@selectdb.com>
AuthorDate: Thu Feb 20 19:14:13 2025 +0800

    branch-3.0: [fix](paimon) avoid get paimon table when replay
---
 .../java/org/apache/doris/datasource/paimon/PaimonExternalTable.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonExternalTable.java
 
b/fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonExternalTable.java
index 20e2a606d88..d234a4e081e 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonExternalTable.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonExternalTable.java
@@ -61,12 +61,11 @@ public class PaimonExternalTable extends ExternalTable 
implements MvccTable {
 
     private static final Logger LOG = 
LogManager.getLogger(PaimonExternalTable.class);
 
-    private final Table paimonTable;
+    private Table paimonTable;
 
     public PaimonExternalTable(long id, String name, String remoteName, 
PaimonExternalCatalog catalog,
             PaimonExternalDatabase db) {
         super(id, name, remoteName, catalog, db, 
TableType.PAIMON_EXTERNAL_TABLE);
-        this.paimonTable = catalog.getPaimonTable(dbName, name);
     }
 
     public String getPaimonCatalogType() {
@@ -76,11 +75,13 @@ public class PaimonExternalTable extends ExternalTable 
implements MvccTable {
     protected synchronized void makeSureInitialized() {
         super.makeSureInitialized();
         if (!objectCreated) {
+            this.paimonTable = ((PaimonExternalCatalog) 
catalog).getPaimonTable(dbName, name);
             objectCreated = true;
         }
     }
 
     public Table getPaimonTable(Optional<MvccSnapshot> snapshot) {
+        makeSureInitialized();
         return paimonTable.copy(
                 Collections.singletonMap(CoreOptions.SCAN_VERSION.key(),
                         
String.valueOf(getOrFetchSnapshotCacheValue(snapshot).getSnapshot().getSnapshotId())));


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org