PIG-5019: Pig generates tons of warnings for udf with enabled warnings aggregation (murshyd via rohini)
git-svn-id: https://svn.apache.org/repos/asf/pig/trunk@1760412 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/CHANGES.txt b/CHANGES.txt
index a503ab2..b5741de 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -44,6 +44,8 @@
BUG FIXES
+PIG-5019: Pig generates tons of warnings for udf with enabled warnings aggregation (murshyd via rohini)
+
PIG-4974: A simple map reference fail to cast (knoguchi)
PIG-4975 Map schema shows "Type: null Uid: null" in explain (knoguchi)
diff --git a/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java b/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
index 291cd60..255650e 100644
--- a/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
+++ b/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
@@ -17,9 +17,6 @@
*/
package org.apache.pig.backend.hadoop.executionengine.mapReduceLayer;
-import java.util.Map;
-import java.util.WeakHashMap;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.pig.EvalFunc;
@@ -41,7 +38,6 @@
private PigStatusReporter reporter = null;
private boolean aggregate = false;
- private Map<Object, String> msgMap = new WeakHashMap<Object, String>();
private PigHadoopLogger() {
}
@@ -68,11 +64,6 @@
if (getAggregate()) {
if (reporter != null) {
- // log at least once
- if (msgMap.get(o) == null || !msgMap.get(o).equals(displayMessage)) {
- log.warn(displayMessage);
- msgMap.put(o, displayMessage);
- }
if (o instanceof EvalFunc || o instanceof LoadFunc || o instanceof StoreFunc) {
reporter.incrCounter(className, warningEnum.name(), 1);
}
