You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ro...@apache.org on 2016/09/12 17:24:30 UTC
svn commit: r1760416 - in /pig/branches/branch-0.16: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
Author: rohini
Date: Mon Sep 12 17:24:30 2016
New Revision: 1760416
URL: http://svn.apache.org/viewvc?rev=1760416&view=rev
Log:
PIG-5019: Pig generates tons of warnings for udf with enabled warnings aggregation (murshyd via rohini)
Modified:
pig/branches/branch-0.16/CHANGES.txt
pig/branches/branch-0.16/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
Modified: pig/branches/branch-0.16/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.16/CHANGES.txt?rev=1760416&r1=1760415&r2=1760416&view=diff
==============================================================================
--- pig/branches/branch-0.16/CHANGES.txt (original)
+++ pig/branches/branch-0.16/CHANGES.txt Mon Sep 12 17:24:30 2016
@@ -30,6 +30,8 @@ OPTIMIZATIONS
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-4967: NPE in PigJobControl.run() when job status is null (water via daijy)
Modified: pig/branches/branch-0.16/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.16/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java?rev=1760416&r1=1760415&r2=1760416&view=diff
==============================================================================
--- pig/branches/branch-0.16/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java (original)
+++ pig/branches/branch-0.16/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java Mon Sep 12 17:24:30 2016
@@ -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 @@ public final class PigHadoopLogger imple
private PigStatusReporter reporter = null;
private boolean aggregate = false;
- private Map<Object, String> msgMap = new WeakHashMap<Object, String>();
private PigHadoopLogger() {
}
@@ -68,11 +64,6 @@ public final class PigHadoopLogger imple
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);
}