diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java index 6cd1f39..41e5a3a 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java @@ -2604,7 +2604,9 @@ private void analyzeAlterTableDropParts(ASTNode ast, boolean expectView) if (partSpecs.isEmpty()) return; // nothing to do validateAlterTableType(tab, AlterTableTypes.DROPPARTITION, expectView); - inputs.add(new ReadEntity(tab)); + ReadEntity re = new ReadEntity(tab); + re.noLockNeeded(); + inputs.add(re); boolean ignoreProtection = ast.getFirstChildWithType(HiveParser.TOK_IGNOREPROTECTION) != null; addTableDropPartsOutputs(tab, partSpecs.values(), !ifExists, ignoreProtection); @@ -3140,7 +3142,7 @@ private void addTableDropPartsOutputs(Table tab, throw new SemanticException( ErrorMsg.DROP_COMMAND_NOT_ALLOWED_FOR_PARTITION.getMsg(p.getCompleteName())); } - outputs.add(new WriteEntity(p, WriteEntity.WriteType.DELETE)); + outputs.add(new WriteEntity(p, WriteEntity.WriteType.DDL_EXCLUSIVE)); } } }