You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2014/06/24 07:43:50 UTC
svn commit: r1605008 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java
Author: hashutosh
Date: Tue Jun 24 05:43:49 2014
New Revision: 1605008
URL: http://svn.apache.org/r1605008
Log:
HIVE-7242 : alter table drop partition is acquiring the wrong type of lock (Alan Gates via Ashutosh Chauhan)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java?rev=1605008&r1=1605007&r2=1605008&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java Tue Jun 24 05:43:49 2014
@@ -2606,7 +2606,9 @@ public class DDLSemanticAnalyzer extends
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);
@@ -3143,7 +3145,7 @@ public class DDLSemanticAnalyzer extends
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));
}
}
}