This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new f98b266 [Bug] Set forceDrop to false when getDropPartitionClause for
DynamicPartitionScheduler to avoid that the deleted partition cannot be
recovered (#5319)
f98b266 is described below
commit f98b26645c45bf7bad39787428593dc0ae1503ef
Author: caiconghui <[email protected]>
AuthorDate: Sun Feb 7 22:36:54 2021 +0800
[Bug] Set forceDrop to false when getDropPartitionClause for
DynamicPartitionScheduler to avoid that the deleted partition cannot be
recovered (#5319)
Co-authored-by: caiconghui [蔡聪辉] <[email protected]>
---
.../src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
index fd57540..32b1872 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
@@ -246,7 +246,7 @@ public class DynamicPartitionScheduler extends MasterDaemon
{
RangeUtils.checkRangeIntersect(reservePartitionKeyRange,
checkDropPartitionKey);
if
(checkDropPartitionKey.upperEndpoint().compareTo(reservePartitionKeyRange.lowerEndpoint())
<= 0) {
String dropPartitionName =
olapTable.getPartition(checkDropPartitionId).getName();
- dropPartitionClauses.add(new DropPartitionClause(false,
dropPartitionName, false, true));
+ dropPartitionClauses.add(new DropPartitionClause(false,
dropPartitionName, false, false));
}
} catch (DdlException e) {
break;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]