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 2010/06/17 23:34:40 UTC
svn commit: r955753 -
/hadoop/pig/trunk/src/org/apache/pig/data/DefaultAbstractBag.java
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);