Author: olga Date: Fri Oct 10 17:25:36 2008 New Revision: 703613 URL: http://svn.apache.org/viewvc?rev=703613&view=rev Log: PIG-475: missing heartbeats
Modified: incubator/pig/branches/types/CHANGES.txt incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapReduce.java Modified: incubator/pig/branches/types/CHANGES.txt URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/CHANGES.txt?rev=703613&r1=703612&r2=703613&view=diff ============================================================================== --- incubator/pig/branches/types/CHANGES.txt (original) +++ incubator/pig/branches/types/CHANGES.txt Fri Oct 10 17:25:36 2008 @@ -280,3 +280,5 @@ via olgan) PIG-489: (*) processing (sms via olgan) + + PIG-475: missing heartbeats (shravanmn via olgan) Modified: incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapReduce.java URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapReduce.java?rev=703613&r1=703612&r2=703613&view=diff ============================================================================== --- incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapReduce.java (original) +++ incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapReduce.java Fri Oct 10 17:25:36 2008 @@ -199,7 +199,8 @@ // which could additionally be called from close() this.outputCollector = oc; pigReporter.setRep(reporter); - + PhysicalOperator.setReporter(pigReporter); + pack.attachInput(key, tupIter); try {