You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pig.apache.org by pr...@apache.org on 2014/11/18 13:40:21 UTC

svn commit: r1640317 - /pig/branches/spark/test/org/apache/pig/test/Util.java

Author: praveen
Date: Tue Nov 18 12:40:20 2014
New Revision: 1640317

URL: http://svn.apache.org/r1640317
Log:
Add Spark support in generateURI used for unit testing (praveen)

Modified:
    pig/branches/spark/test/org/apache/pig/test/Util.java

Modified: pig/branches/spark/test/org/apache/pig/test/Util.java
URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/Util.java?rev=1640317&r1=1640316&r2=1640317&view=diff
==============================================================================
--- pig/branches/spark/test/org/apache/pig/test/Util.java (original)
+++ pig/branches/spark/test/org/apache/pig/test/Util.java Tue Nov 18 12:40:20 2014
@@ -734,7 +734,8 @@ public class Util {
         if(Util.WINDOWS){
             filename = filename.replace('\\','/');
         }
-        if (context.getExecType() == ExecType.MAPREDUCE || context.getExecType().name().equals("TEZ")) {
+        if (context.getExecType() == ExecType.MAPREDUCE || context.getExecType().name().equals("TEZ") ||
+                context.getExecType().name().equals("SPARK")) {
             return FileLocalizer.hadoopify(filename, context);
         } else if (context.getExecType().isLocal()) {
             return filename;