mrql-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fega...@apache.org
Subject incubator-mrql git commit: MRQL-62: Fix Map-Reduce mode on MultipleInput sources
Date Fri, 16 Jan 2015 20:37:37 GMT
Repository: incubator-mrql
Updated Branches:
  refs/heads/master d3f61f9df -> ce2ff692d


MRQL-62: Fix Map-Reduce mode on MultipleInput sources


Project: http://git-wip-us.apache.org/repos/asf/incubator-mrql/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mrql/commit/ce2ff692
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mrql/tree/ce2ff692
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mrql/diff/ce2ff692

Branch: refs/heads/master
Commit: ce2ff692db644adf0c682a0f23e46ad831bdf709
Parents: d3f61f9
Author: fegaras <fegaras@cse.uta.edu>
Authored: Fri Jan 16 14:37:10 2015 -0600
Committer: fegaras <fegaras@cse.uta.edu>
Committed: Fri Jan 16 14:37:10 2015 -0600

----------------------------------------------------------------------
 mapreduce/src/main/java/org/apache/mrql/MapReduceEvaluator.gen | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-mrql/blob/ce2ff692/mapreduce/src/main/java/org/apache/mrql/MapReduceEvaluator.gen
----------------------------------------------------------------------
diff --git a/mapreduce/src/main/java/org/apache/mrql/MapReduceEvaluator.gen b/mapreduce/src/main/java/org/apache/mrql/MapReduceEvaluator.gen
index 84d82e5..2974bd9 100644
--- a/mapreduce/src/main/java/org/apache/mrql/MapReduceEvaluator.gen
+++ b/mapreduce/src/main/java/org/apache/mrql/MapReduceEvaluator.gen
@@ -64,7 +64,8 @@ final public class MapReduceEvaluator extends Evaluator {
         for ( Map.Entry<String,String> entry: old_conf )
             if (entry.getKey().startsWith("mrql.") && entry.getValue() != null)
                 conf.set(entry.getKey(),entry.getValue());
-        conf.set("mapred.input.dir.formats","");  // need to reset MultipleInputs for local
mode
+        // old Configuration doesn't have unset
+        // conf.unset("mapred.input.dir.formats");  // need to reset MultipleInputs for local
mode
         return conf;
     }
 


Mime
View raw message