You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrql.apache.org by fe...@apache.org on 2015/01/16 21:37:37 UTC
incubator-mrql git commit: MRQL-62: Fix Map-Reduce mode on
MultipleInput sources
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 <fe...@cse.uta.edu>
Authored: Fri Jan 16 14:37:10 2015 -0600
Committer: fegaras <fe...@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;
}