This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 0a2a03500820aea1bc6f572c7d9975a75d4f63b9
Author: Luwei <814383...@qq.com>
AuthorDate: Tue Apr 9 23:18:52 2024 +0800
[fix](merge-cloud) fix possible data leak when creating tables (#33416)
---
.../src/main/java/org/apache/doris/datasource/InternalCatalog.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
index 2bd2f21478b..c9e59d34147 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -1673,6 +1673,8 @@ public class InternalCatalog implements
CatalogIf<Database> {
partitionInfo.getReplicaAllocation(partitionId),
partitionInfo.getIsInMemory(partitionId),
isTempPartition,
partitionInfo.getIsMutable(partitionId));
}
+
+ afterCreatePartitions(db.getId(), olapTable.getId(),
partitionIds, indexIds, false);
Env.getCurrentEnv().getEditLog().logAddPartition(info);
LOG.info("succeed in creating partition[{}], temp: {}",
partitionId, isTempPartition);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
