This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 29b7860cdb4 [fix](merge-cloud) fix possible data leak when creating
tables (#33416)
29b7860cdb4 is described below
commit 29b7860cdb46e66d90329a40b4b35f8c3e0308b1
Author: Luwei <[email protected]>
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 | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 d19704753ec..d0e52b9ff05 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
@@ -1616,7 +1616,6 @@ public class InternalCatalog implements
CatalogIf<Database> {
singlePartitionDesc.getTabletType(),
storagePolicy, idGeneratorBuffer,
binlogConfig, dataProperty.isStorageMediumSpecified(),
null);
- afterCreatePartitions(db.getId(), olapTable.getId(), partitionIds,
indexIds, false);
// TODO cluster key ids
// check again
@@ -1712,6 +1711,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: [email protected]
For additional commands, e-mail: [email protected]
