Package org.apache.commons.logging

Examples of org.apache.commons.logging.Log.warn()

427
428
429
430
431
432
433
434
435
436
437
                        if(BuiltInFunction.EXT_NSPREFIX.equals(prefix)) {
                            table.put(name, f);
                            String clazzName = f.getClass().getName();
                            r.put(name, clazzName);
                        } else {
                            LOG.warn("loading a BuiltInFunction is discarded: " + name);
                        }

                    }
                }
            } else {
View Full Code Here
434
435
436
437
438
439
440
441
442
443
444
                    }
                }
            } else {
                Log LOG = LogFactory.getLog(PredefinedFunctions.class);
                LOG.warn("Illegal FunctionProvider: " + providerClazz);
            }
        }
    }

}
View Full Code Here
2314
2315
2316
2317
2318
2319
2320
2321
2322
2323
2324
          (TaskTracker) context.getAttribute("task.tracker");
        Log log = (Log) context.getAttribute("log");
        String errorMsg = ("getMapOutput(" + mapId + "," + reduceId +
                           ") failed :\n"+
                           StringUtils.stringifyException(ie));
        log.warn(errorMsg);
        if (isInputException) {
          tracker.mapOutputLost(mapId, errorMsg);
        }
        response.sendError(HttpServletResponse.SC_GONE, errorMsg);
        shuffleMetrics.failedOutput();
View Full Code Here
1992
1993
1994
1995
1996
1997
1998
1999
2000
2001
2002
          (TaskTracker) context.getAttribute("task.tracker");
        Log log = (Log) context.getAttribute("log");
        String errorMsg = ("getMapOutput(" + mapId + "," + reduceId +
                           ") failed :\n"+
                           StringUtils.stringifyException(ie));
        log.warn(errorMsg);
        if (isInputException) {
          tracker.mapOutputLost(mapId, errorMsg);
        }
        response.sendError(HttpServletResponse.SC_GONE, errorMsg);
        shuffleMetrics.failedOutput();
View Full Code Here
3675
3676
3677
3678
3679
3680
3681
3682
3683
3684
3685
      } catch (IOException ie) {
        Log log = (Log) context.getAttribute("log");
        String errorMsg = ("getMapOutput(" + mapId + "," + reduceId +
                           ") failed :\n"+
                           StringUtils.stringifyException(ie));
        log.warn(errorMsg);
        if (isInputException) {
          tracker.mapOutputLost(TaskAttemptID.forName(mapId), errorMsg);
        }
        response.sendError(HttpServletResponse.SC_GONE, errorMsg);
        shuffleMetrics.failedOutput();
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
          if (sortColumnName == null)
            throw new IOException("Zebra does not support column positional reference yet");
          if (sortColumn.getSortOrder() == Order.DESCENDING)
          {
            Log LOG = LogFactory.getLog(TableLoader.class);
            LOG.warn("Sorting in descending order is not supported by Zebra and the table will be unsorted.");
            descending = true;
            break;
          }
          if (!org.apache.pig.data.DataType.isAtomic(schema.getField(sortColumnName).type))
            throw new IOException(schema.getField(sortColumnName).alias+" is not of simple type as required for a sort column now.");
View Full Code Here
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
                } catch (SecurityException e) {
                    // don't know - so display warning
                    vulnerableJVM = true;
                }
                if (vulnerableJVM) {
                    log.warn(
                        "Current Security Manager restricts use of workarounds for reflection bugs "
                        + " in pre-1.4 JVMs.");
                }
                loggedAccessibleWarning = true;
            }
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
                // prefix passed to the addRules method. Plugins mustn't
                // add rules outside the scope of the tag they were specified
                // on, so refuse this.
               
                // alas, can't throw exception
                log.warn(
                    "An attempt was made to add a rule with a pattern that"
                    + "is not at or below the mountpoint of the current"
                    + " PluginRules object."
                    + " Rule pattern: " + pattern
                    + ", mountpoint: " + mountPoint
View Full Code Here
1953
1954
1955
1956
1957
1958
1959
1960
1961
1962
1963
          (TaskTracker) context.getAttribute("task.tracker");
        Log log = (Log) context.getAttribute("log");
        String errorMsg = ("getMapOutput(" + mapId + "," + reduceId +
                           ") failed :\n"+
                           StringUtils.stringifyException(ie));
        log.warn(errorMsg);
        if (isInputException) {
          tracker.mapOutputLost(mapId, errorMsg);
        }
        response.sendError(HttpServletResponse.SC_GONE, errorMsg);
        throw ie;
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        TableFObj parent = (TableFObj) propertyList.getParentFObj();
       
        int columnIndex = p.getNumeric().getValue();
        if (columnIndex <= 0) {
            Log log = LogFactory.getLog(TableFObj.class);
            log.warn("Specified negative or zero value for "
                    + "column-number on " + fo.getName() + ": "
                    + columnIndex + " forced to "
                    + parent.getCurrentColumnIndex());
            return NumberProperty.getInstance(parent.getCurrentColumnIndex());
        } else {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.