pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r955753 - /hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java
Date Thu, 17 Jun 2010 21:34:40 GMT
Author: daijy
Date: Thu Jun 17 21:34:40 2010
New Revision: 955753

URL: http://svn.apache.org/viewvc?rev=955753&view=rev
Log:
Fix TestDataBag failure for PIG-1428

Modified:
    hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java

Modified: hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java?rev=955753&r1=955752&r2=955753&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java Thu Jun 17 21:34:40 2010
@@ -375,7 +375,7 @@ public abstract class DefaultAbstractBag
     
     protected void incSpillCount(Enum counter) {
         PigStatusReporter reporter = PigStatusReporter.getInstance();
-        if (reporter != null) {
+        if (reporter != null && reporter.getCounter(counter)!=null) {
             reporter.getCounter(counter).increment(1);
         } else {
             PigHadoopLogger.getInstance().warn(this, "Spill counter incremented", counter);



Mime
View raw message