Repository: tez Updated Branches: refs/heads/master af1884a12 -> 62bbbdb78
TEZ-1354. Fix NPE in FilterByWordOutputProcessor. Contributed by Jonathan Eagles. Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/62bbbdb7 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/62bbbdb7 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/62bbbdb7 Branch: refs/heads/master Commit: 62bbbdb78d6060688be33afe8dcec0a89eb0daa1 Parents: af1884a Author: Siddharth Seth <[email protected]> Authored: Thu Jul 31 13:55:22 2014 -0700 Committer: Siddharth Seth <[email protected]> Committed: Thu Jul 31 13:55:22 2014 -0700 ---------------------------------------------------------------------- .../org/apache/tez/processor/FilterByWordOutputProcessor.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/62bbbdb7/tez-mapreduce-examples/src/main/java/org/apache/tez/processor/FilterByWordOutputProcessor.java ---------------------------------------------------------------------- diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/processor/FilterByWordOutputProcessor.java b/tez-mapreduce-examples/src/main/java/org/apache/tez/processor/FilterByWordOutputProcessor.java index bad2b9c..bf07735 100644 --- a/tez-mapreduce-examples/src/main/java/org/apache/tez/processor/FilterByWordOutputProcessor.java +++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/processor/FilterByWordOutputProcessor.java @@ -26,9 +26,7 @@ import org.apache.commons.logging.LogFactory; import org.apache.tez.mapreduce.output.MROutput; import org.apache.tez.mapreduce.processor.map.MapProcessor; import org.apache.tez.runtime.api.AbstractLogicalIOProcessor; -import org.apache.tez.runtime.api.AbstractLogicalInput; import org.apache.tez.runtime.api.Event; -import org.apache.tez.runtime.api.LogicalIOProcessor; import org.apache.tez.runtime.api.LogicalInput; import org.apache.tez.runtime.api.LogicalOutput; import org.apache.tez.runtime.api.TezProcessorContext; @@ -40,7 +38,6 @@ import org.apache.tez.runtime.library.input.ShuffledUnorderedKVInput; public class FilterByWordOutputProcessor extends AbstractLogicalIOProcessor { private static final Log LOG = LogFactory.getLog(MapProcessor.class); - private TezProcessorContext processorContext; public FilterByWordOutputProcessor(TezProcessorContext context) { super(context); @@ -101,7 +98,7 @@ public class FilterByWordOutputProcessor extends AbstractLogicalIOProcessor { kvWriter.write(key, value); } - if (processorContext.canCommit()) { + if (getContext().canCommit()) { mrOutput.commit(); } else { mrOutput.abort();
