Repository: hive Updated Branches: refs/heads/master 97d308d6b -> f476fb4f9
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/f476fb4f Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f476fb4f Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f476fb4f Branch: refs/heads/master Commit: f476fb4f9e2dfd89995dca4fd9b321a042235af5 Parents: 97d308d6 Author: Prasanth Jayachandran <prasan...@apache.org> Authored: Thu Jun 14 23:05:46 2018 -0700 Committer: Prasanth Jayachandran <prasan...@apache.org> Committed: Thu Jun 14 23:05:46 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/f476fb4f/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);
