diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java index d1a710bcf9..dd39b12a18 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/PropertyAnalyzer.java @@ -1311,14 +1311,15 @@ public class PropertyAnalyzer { throw new AnalysisException(PropertyAnalyzer.ENABLE_UNIQUE_KEY_MERGE_ON_WRITE + " must be `true` or `false`"); } - public static boolean analyzeEnableDeleteOnDeletePredicate(Map properties) + public static boolean analyzeEnableDeleteOnDeletePredicate(Map properties, + boolean enableUniqueKeyMergeOnWrite) throws AnalysisException { if (properties == null || properties.isEmpty()) { - return false; + return enableUniqueKeyMergeOnWrite ? Config.enable_mow_light_delete : false; } String value = properties.get(PropertyAnalyzer.PROPERTIES_ENABLE_MOW_LIGHT_DELETE); if (value == null) { - return false; + return enableUniqueKeyMergeOnWrite ? Config.enable_mow_light_delete : false; } properties.remove(PropertyAnalyzer.PROPERTIES_ENABLE_MOW_LIGHT_DELETE); if (value.equals("true")) { 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 1fb8826903..46b1c44fa2 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 @@ -2498,7 +2498,8 @@ public class InternalCatalog implements CatalogIf { boolean enableDeleteOnDeletePredicate = false; try { - enableDeleteOnDeletePredicate = PropertyAnalyzer.analyzeEnableDeleteOnDeletePredicate(properties); + enableDeleteOnDeletePredicate = PropertyAnalyzer.analyzeEnableDeleteOnDeletePredicate(properties, + enableUniqueKeyMergeOnWrite); } catch (AnalysisException e) { throw new DdlException(e.getMessage()); }