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);


Reply via email to