hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sunc...@apache.org
Subject svn commit: r1666034 - /hive/branches/spark/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java
Date Wed, 11 Mar 2015 23:09:42 GMT
Author: sunchao
Date: Wed Mar 11 23:09:41 2015
New Revision: 1666034

URL: http://svn.apache.org/r1666034
Log:
HIVE-9916 - Fix TestSparkSessionManagerImpl [Spark Branch] (Chao via Xuefu)

Modified:
    hive/branches/spark/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java

Modified: hive/branches/spark/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java?rev=1666034&r1=1666033&r2=1666034&view=diff
==============================================================================
--- hive/branches/spark/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java
(original)
+++ hive/branches/spark/ql/src/test/org/apache/hadoop/hive/ql/exec/spark/session/TestSparkSessionManagerImpl.java
Wed Mar 11 23:09:41 2015
@@ -42,6 +42,7 @@ public class TestSparkSessionManagerImpl
   @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 class TestSparkSessionManagerImpl
     sessionManagerHS2.shutdown();
 
     HiveConf hiveConf = new HiveConf();
+    hiveConf.set("spark.master", "local");
+
     sessionManagerHS2.setup(hiveConf);
 
     List<Thread> threadList = new ArrayList<Thread>();
@@ -105,6 +108,8 @@ public class TestSparkSessionManagerImpl
         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;
 



Mime
View raw message