You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/10/01 20:01:37 UTC
svn commit: r1628791 - in /pig/trunk: CHANGES.txt test/org/apache/pig/test/TestMRJobStats.java

Author: daijy
Date: Wed Oct  1 18:01:37 2014
New Revision: 1628791

URL: http://svn.apache.org/r1628791
Log:
PIG-4214: Fix unit test fail TestMRJobStats

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/test/org/apache/pig/test/TestMRJobStats.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1628791&r1=1628790&r2=1628791&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Oct  1 18:01:37 2014
@@ -92,6 +92,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4214: Fix unit test fail TestMRJobStats (daijy)
+
 PIG-4217: Fix documentation in BuildBloom (praveenr019 via daijy)
 
 PIG-4215: Fix unit test failure TestParamSubPreproc and TestMacroExpansion (daijy)

Modified: pig/trunk/test/org/apache/pig/test/TestMRJobStats.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/TestMRJobStats.java?rev=1628791&r1=1628790&r2=1628791&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/TestMRJobStats.java (original)
+++ pig/trunk/test/org/apache/pig/test/TestMRJobStats.java Wed Oct  1 18:01:37 2014
@@ -27,6 +27,8 @@ import java.io.PrintWriter;
 import java.io.RandomAccessFile;
 import java.lang.reflect.Constructor;
 import java.lang.reflect.Method;
+import java.util.Arrays;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Properties;
 
@@ -126,8 +128,8 @@ public class TestMRJobStats {
         getJobStatsMethod("setId", JobID.class).invoke(jobStats, jobID);
         jobStats.setSuccessful(true);
 
-        getJobStatsMethod("addMapReduceStatistics", TaskReport[].class, TaskReport[].class)
-            .invoke(jobStats, mapTaskReports, reduceTaskReports);
+        getJobStatsMethod("addMapReduceStatistics", Iterator.class, Iterator.class)
+            .invoke(jobStats, Arrays.asList(mapTaskReports).iterator(), Arrays.asList(reduceTaskReports).iterator());
         String msg = (String)getJobStatsMethod("getDisplayString")
             .invoke(jobStats);
 
@@ -156,8 +158,8 @@ public class TestMRJobStats {
         getJobStatsMethod("setId", JobID.class).invoke(jobStats, jobID);
         jobStats.setSuccessful(true);
 
-        getJobStatsMethod("addMapReduceStatistics", TaskReport[].class, TaskReport[].class)
-            .invoke(jobStats, mapTaskReports, reduceTaskReports);
+        getJobStatsMethod("addMapReduceStatistics", Iterator.class, Iterator.class)
+            .invoke(jobStats, Arrays.asList(mapTaskReports).iterator(), Arrays.asList(reduceTaskReports).iterator());
         String msg = (String)getJobStatsMethod("getDisplayString")
             .invoke(jobStats);
         System.out.println(JobStats.SUCCESS_HEADER);