Skip to content

Loading…

Fix issue where MapReduceTargets that aren't also PathTargets don't get configured. #22

Merged
merged 1 commit into from

2 participants

@robotoer

Changed configuration of MSCROutputHandler to configure MapReduceTargets as well as HBaseTargets.

Robert Chu Fix issue where MapReduceTargets that aren't also PathTargets don't g…
…et configured.

Changed configuration of MSCROutputHandler to configure MapReduceTargets as well as
HBaseTargets.
0e369bb
@jwills jwills merged commit a13e0d2 into cloudera:master
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Commits on May 8, 2012
  1. Fix issue where MapReduceTargets that aren't also PathTargets don't g…

    Robert Chu committed
    …et configured.
    
    Changed configuration of MSCROutputHandler to configure MapReduceTargets as well as
    HBaseTargets.
Showing with 2 additions and 3 deletions.
  1. +2 −3 src/main/java/com/cloudera/crunch/impl/mr/plan/MSCROutputHandler.java
View
5 src/main/java/com/cloudera/crunch/impl/mr/plan/MSCROutputHandler.java
@@ -23,7 +23,6 @@
import com.cloudera.crunch.io.MapReduceTarget;
import com.cloudera.crunch.io.OutputHandler;
import com.cloudera.crunch.io.PathTarget;
-import com.cloudera.crunch.io.hbase.HBaseTarget;
import com.cloudera.crunch.type.PType;
import com.google.common.collect.Lists;
@@ -56,8 +55,8 @@ public boolean configure(Target target, PType<?> ptype) {
((MapReduceTarget) target).configureForMapReduce(job, ptype, path, name);
return true;
}
- if (target instanceof HBaseTarget) {
- ((HBaseTarget) target).configureForMapReduce(job, null, null, null);
+ if (target instanceof MapReduceTarget) {
+ ((MapReduceTarget) target).configureForMapReduce(job, ptype, null, null);
return true;
}
return false;
Something went wrong with that request. Please try again.