HIVE-12073 : LLAP: disable session reuse for MiniTez cluster (Sergey Shelukhin)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/4cc2089e Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/4cc2089e Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/4cc2089e Branch: refs/heads/master Commit: 4cc2089e0a9d2e0aa92218e3010b1d06dbc42bed Parents: 3cd915b Author: Sergey Shelukhin <[email protected]> Authored: Thu Oct 8 13:21:01 2015 -0700 Committer: Sergey Shelukhin <[email protected]> Committed: Thu Oct 8 13:21:01 2015 -0700 ---------------------------------------------------------------------- .../util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/4cc2089e/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java ---------------------------------------------------------------------- diff --git a/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java index 477a08d..174a988 100644 --- a/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java +++ b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java @@ -955,7 +955,7 @@ public class QTestUtil { ss.setIsSilent(true); SessionState oldSs = SessionState.get(); - if (oldSs != null && (clusterType == MiniClusterType.tez || clusterType == MiniClusterType.llap + if (oldSs != null && (clusterType == MiniClusterType.llap || clusterType == MiniClusterType.spark || clusterType == MiniClusterType.miniSparkOnYarn)) { sparkSession = oldSs.getSparkSession(); ss.setSparkSession(sparkSession); @@ -1023,7 +1023,7 @@ public class QTestUtil { ss.err = System.out; SessionState oldSs = SessionState.get(); - if (oldSs != null && (clusterType == MiniClusterType.tez || clusterType == MiniClusterType.llap + if (oldSs != null && (clusterType == MiniClusterType.llap || clusterType == MiniClusterType.miniSparkOnYarn || clusterType == MiniClusterType.miniSparkOnYarn)) { sparkSession = oldSs.getSparkSession(); ss.setSparkSession(sparkSession);
