diff --git a/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java b/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java index e74ed87..4d93ea6 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java @@ -42,6 +42,7 @@ @Test public void testSingleSessionMultipleUse() throws Exception { HiveConf conf = new HiveConf(); + conf.set("spark.master", "local"); SparkSessionManager sessionManager = SparkSessionManagerImpl.getInstance(); SparkSession sparkSession1 = sessionManager.getSession(null, conf, true); @@ -68,6 +69,8 @@ public void testMultiSessionMultipleUse() throws Exception { sessionManagerHS2.shutdown(); HiveConf hiveConf = new HiveConf(); + hiveConf.set("spark.master", "local"); + sessionManagerHS2.setup(hiveConf); List threadList = new ArrayList(); @@ -105,6 +108,8 @@ public void run() { String threadName = Thread.currentThread().getName(); System.out.println(threadName + " started."); HiveConf conf = new HiveConf(); + conf.set("spark.master", "local"); + SparkSession prevSession = null; SparkSession currentSession = null;