You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2018/06/15 06:06:22 UTC
hive git commit: HIVE-19877: Remove setting hive.execution.engine as
mr in HiveStreamingConnection (Prasanth Jayachandran reviewed by Eugene
Koifman)
Repository: hive
Updated Branches:
refs/heads/branch-3 06d8f362e -> 1218619f6
HIVE-19877: Remove setting hive.execution.engine as mr in HiveStreamingConnection (Prasanth Jayachandran reviewed by Eugene Koifman)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/1218619f
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1218619f
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1218619f
Branch: refs/heads/branch-3
Commit: 1218619f65bb28b26bd5bb06a77919d64ac4eb8d
Parents: 06d8f36
Author: Prasanth Jayachandran <pr...@apache.org>
Authored: Thu Jun 14 23:05:46 2018 -0700
Committer: Prasanth Jayachandran <pr...@apache.org>
Committed: Thu Jun 14 23:06:04 2018 -0700
----------------------------------------------------------------------
.../java/org/apache/hive/streaming/HiveStreamingConnection.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/1218619f/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
----------------------------------------------------------------------
diff --git a/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java b/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
index 1d8fdff..d258d0e 100644
--- a/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
+++ b/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
@@ -1017,8 +1017,6 @@ public class HiveStreamingConnection implements StreamingConnection {
setHiveConf(conf, HiveConf.ConfVars.HIVE_TXN_MANAGER, DbTxnManager.class.getName());
setHiveConf(conf, HiveConf.ConfVars.HIVE_SUPPORT_CONCURRENCY, true);
setHiveConf(conf, MetastoreConf.ConfVars.EXECUTE_SET_UGI.getHiveName());
- // Avoids creating Tez Client sessions internally as it takes much longer currently
- setHiveConf(conf, HiveConf.ConfVars.HIVE_EXECUTION_ENGINE, "mr");
setHiveConf(conf, HiveConf.ConfVars.DYNAMICPARTITIONINGMODE, "nonstrict");
if (streamingOptimizations) {
setHiveConf(conf, HiveConf.ConfVars.HIVE_ORC_DELTA_STREAMING_OPTIMIZATIONS_ENABLED, true);