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:02 UTC
svn commit: r1628790 - in /pig/branches/branch-0.14: CHANGES.txt
test/org/apache/pig/test/TestMRJobStats.java
Author: daijy
Date: Wed Oct 1 18:01:01 2014
New Revision: 1628790
URL: http://svn.apache.org/r1628790
Log:
PIG-4214: Fix unit test fail TestMRJobStats
Modified:
pig/branches/branch-0.14/CHANGES.txt
pig/branches/branch-0.14/test/org/apache/pig/test/TestMRJobStats.java
Modified: pig/branches/branch-0.14/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.14/CHANGES.txt?rev=1628790&r1=1628789&r2=1628790&view=diff
==============================================================================
--- pig/branches/branch-0.14/CHANGES.txt (original)
+++ pig/branches/branch-0.14/CHANGES.txt Wed Oct 1 18:01:01 2014
@@ -84,6 +84,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/branches/branch-0.14/test/org/apache/pig/test/TestMRJobStats.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.14/test/org/apache/pig/test/TestMRJobStats.java?rev=1628790&r1=1628789&r2=1628790&view=diff
==============================================================================
--- pig/branches/branch-0.14/test/org/apache/pig/test/TestMRJobStats.java (original)
+++ pig/branches/branch-0.14/test/org/apache/pig/test/TestMRJobStats.java Wed Oct 1 18:01:01 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);