This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new e3535cccbf6 [fix](external catalog) Reset external table creation
status on log replay (#33391)
e3535cccbf6 is described below
commit e3535cccbf616e84f5230522c059cf77e14f3269
Author: zy-kkk <[email protected]>
AuthorDate: Tue Apr 9 10:15:45 2024 +0800
[fix](external catalog) Reset external table creation status on log replay
(#33391)
---
.../java/org/apache/doris/catalog/external/ExternalDatabase.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java
index 3559637b8f3..8df3a0a8316 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java
@@ -141,8 +141,11 @@ public abstract class ExternalDatabase<T extends
ExternalTable>
Map<Long, T> tmpIdToTbl = Maps.newConcurrentMap();
for (int i = 0; i < log.getRefreshCount(); i++) {
T table = getTableForReplay(log.getRefreshTableIds().get(i));
- tmpTableNameToId.put(table.getName(), table.getId());
- tmpIdToTbl.put(table.getId(), table);
+ if (table != null) {
+ table.unsetObjectCreated();
+ tmpTableNameToId.put(table.getName(), table.getId());
+ tmpIdToTbl.put(table.getId(), table);
+ }
}
for (int i = 0; i < log.getCreateCount(); i++) {
T table = getExternalTable(log.getCreateTableNames().get(i),
log.getCreateTableIds().get(i), catalog);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
