Author: xuefu
Date: Thu Mar 10 15:42:41 2016
New Revision: 1734427
URL: http://svn.apache.org/viewvc?rev=1734427&view=rev
Log:
PIG-4836: Fix TestEvalPipeline test failure (Pallavi via Xuefu)
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java?rev=1734427&r1=1734426&r2=1734427&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java
Thu Mar 10 15:42:41 2016
@@ -25,6 +25,7 @@ import java.util.List;
import org.apache.hadoop.mapred.JobConf;
import org.apache.pig.backend.executionengine.ExecException;
import
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce;
+import
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ProgressableReporter;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.Result;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc;
@@ -90,6 +91,8 @@ public class ForEachConverter implements
public Iterable<Tuple> call(final Iterator<Tuple> input) {
initializeJobConf();
+ // Initialize a reporter as the UDF might want to report progress.
+ PhysicalOperator.setReporter(new ProgressableReporter());
PhysicalOperator[] planLeafOps= poForEach.getPlanLeafOps();
if (planLeafOps != null) {
for (PhysicalOperator op : planLeafOps) {
