You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ek...@apache.org on 2016/01/21 00:37:44 UTC

hive git commit: HIVE-12890 Disable multi-statment transaction control statements until HIVE-11078 (Eugene Koifman, reviewed by Sergey Shelukhin)

Repository: hive
Updated Branches:
  refs/heads/branch-2.0 9545f6dbf -> 5fb36dbac


HIVE-12890 Disable multi-statment transaction control statements until HIVE-11078 (Eugene Koifman, reviewed by Sergey Shelukhin)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/5fb36dba
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/5fb36dba
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/5fb36dba

Branch: refs/heads/branch-2.0
Commit: 5fb36dbace1d50e0843b3e362664b627fe143b19
Parents: 9545f6d
Author: Eugene Koifman <ek...@hortonworks.com>
Authored: Wed Jan 20 15:37:39 2016 -0800
Committer: Eugene Koifman <ek...@hortonworks.com>
Committed: Wed Jan 20 15:37:39 2016 -0800

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java   | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/5fb36dba/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
index 34144e7..92475bf 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
@@ -10028,6 +10028,10 @@ public class SemanticAnalyzer extends BaseSemanticAnalyzer {
       case HiveParser.TOK_START_TRANSACTION:
       case HiveParser.TOK_COMMIT:
       case HiveParser.TOK_ROLLBACK:
+        if(!(conf.getBoolVar(ConfVars.HIVE_IN_TEST) || conf.getBoolVar(ConfVars.HIVE_IN_TEZ_TEST))) {
+          throw new IllegalStateException(SemanticAnalyzerFactory.getOperation(ast.getToken().getType()) +
+            " is not supported yet.");
+        }
         SessionState.get().setCommandType(SemanticAnalyzerFactory.getOperation(ast.getToken().getType()));
         return false;
     }