svn commit: r1645891 - /pig/branches/spark/shims/test/hadoop23/org/apache/pig/test/SparkMiniCluster.java

[praveen]

Author: praveen
Date: Tue Dec 16 09:40:48 2014
New Revision: 1645891

URL: http://svn.apache.org/r1645891
Log:
PIG-4268: Enable unit test "TestStreamingUDF" in spark (liyunzhang via praveen)

Modified:
    
pig/branches/spark/shims/test/hadoop23/org/apache/pig/test/SparkMiniCluster.java

Modified: 
pig/branches/spark/shims/test/hadoop23/org/apache/pig/test/SparkMiniCluster.java
URL: 
http://svn.apache.org/viewvc/pig/branches/spark/shims/test/hadoop23/org/apache/pig/test/SparkMiniCluster.java?rev=1645891&r1=1645890&r2=1645891&view=diff
==============================================================================
--- 
pig/branches/spark/shims/test/hadoop23/org/apache/pig/test/SparkMiniCluster.java
 (original)
+++ 
pig/branches/spark/shims/test/hadoop23/org/apache/pig/test/SparkMiniCluster.java
 Tue Dec 16 09:40:48 2014
@@ -35,6 +35,7 @@ public class SparkMiniCluster extends Mi
             int dataNodes = 4;
             m_dfs = new MiniDFSCluster(m_conf, dataNodes, true, null);
             m_fileSys = m_dfs.getFileSystem();
+            m_fileSys.mkdirs(m_fileSys.getWorkingDirectory());
         } catch (IOException e) {
             throw new RuntimeException(e);