Skip to content

Commit dbce2e9

Browse files
committed
branch-2.1: [fix](paimon) avoid get paimon table when replay
1 parent 150d707 commit dbce2e9

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonExternalTable.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,12 +61,11 @@ public class PaimonExternalTable extends ExternalTable implements MvccTable {
6161

6262
private static final Logger LOG = LogManager.getLogger(PaimonExternalTable.class);
6363

64-
private final Table paimonTable;
64+
private Table paimonTable;
6565

6666
public PaimonExternalTable(long id, String name, String remoteName, PaimonExternalCatalog catalog,
6767
PaimonExternalDatabase db) {
6868
super(id, name, remoteName, catalog, db, TableType.PAIMON_EXTERNAL_TABLE);
69-
this.paimonTable = catalog.getPaimonTable(dbName, name);
7069
}
7170

7271
public String getPaimonCatalogType() {
@@ -76,11 +75,13 @@ public String getPaimonCatalogType() {
7675
protected synchronized void makeSureInitialized() {
7776
super.makeSureInitialized();
7877
if (!objectCreated) {
78+
this.paimonTable = ((PaimonExternalCatalog) catalog).getPaimonTable(dbName, name);
7979
objectCreated = true;
8080
}
8181
}
8282

8383
public Table getPaimonTable(Optional<MvccSnapshot> snapshot) {
84+
makeSureInitialized();
8485
return paimonTable.copy(
8586
Collections.singletonMap(CoreOptions.SCAN_VERSION.key(),
8687
String.valueOf(getOrFetchSnapshotCacheValue(snapshot).getSnapshot().getSnapshotId())));

0 commit comments

Comments
 (0)