diff --git ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java index 6513e0f203..5a95649f5b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java +++ ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java @@ -514,7 +514,7 @@ Seems much cleaner if each stmt is identified as a particular HiveOperation (whi break; case INSERT: assert t != null; - if(AcidUtils.isFullAcidTable(t)) { + if(AcidUtils.isTransactionalTable(t)) { compBuilder.setShared(); } else { diff --git ql/src/test/queries/clientnegative/mm_convert.q ql/src/test/queries/clientnegative/mm_convert.q index acbf4bbf34..ff44387471 100644 --- ql/src/test/queries/clientnegative/mm_convert.q +++ ql/src/test/queries/clientnegative/mm_convert.q @@ -2,6 +2,8 @@ set hive.mapred.mode=nonstrict; set hive.explain.user=false; set hive.fetch.task.conversion=none; set hive.exec.dynamic.partition.mode=nonstrict; +set hive.support.concurrency=true; +set hive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager; drop table convert_mm; create table convert_mm(key int, id int) tblproperties("transactional"="true", "transactional_properties"="insert_only"); diff --git ql/src/test/queries/clientnegative/mm_truncate_cols.q ql/src/test/queries/clientnegative/mm_truncate_cols.q index 3335ed84b4..a4dae38fac 100644 --- ql/src/test/queries/clientnegative/mm_truncate_cols.q +++ ql/src/test/queries/clientnegative/mm_truncate_cols.q @@ -1,3 +1,6 @@ +set hive.support.concurrency=true; +set hive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager; + CREATE TABLE mm_table(key int, value string) stored as rcfile tblproperties ("transactional"="true", "transactional_properties"="insert_only"); TRUNCATE TABLE mm_table COLUMNS (value);