You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by an...@apache.org on 2014/01/25 06:29:07 UTC
svn commit: r1561259 -
/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
Author: aniket486
Date: Sat Jan 25 05:29:06 2014
New Revision: 1561259
URL: http://svn.apache.org/r1561259
Log:
PIG-2207: Add missing null check for msgMap
Modified:
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java?rev=1561259&r1=1561258&r2=1561259&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java Sat Jan 25 05:29:06 2014
@@ -62,7 +62,7 @@ public final class PigHadoopLogger imple
if (getAggregate()) {
if (reporter != null) {
// log atleast once
- if (!msgMap.get(o).equals(displayMessage)) {
+ if (msgMap.get(o) == null || !msgMap.get(o).equals(displayMessage)) {
log.warn(displayMessage);
msgMap.put(o, displayMessage);
}