You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by jo...@apache.org on 2017/11/28 20:40:05 UTC
[04/12] ambari git commit: AMBARI-22526. Log Feeder: handle multiple
'=' (split char) in key/value filter (oleewere)
AMBARI-22526. Log Feeder: handle multiple '=' (split char) in key/value filter (oleewere)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/4fe795db
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/4fe795db
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/4fe795db
Branch: refs/heads/branch-feature-AMBARI-22457
Commit: 4fe795dba0a5451159c0afa8cc273b181887dd10
Parents: 812ded6
Author: Oliver Szabo <ol...@gmail.com>
Authored: Tue Nov 28 14:48:35 2017 +0100
Committer: Oliver Szabo <ol...@gmail.com>
Committed: Tue Nov 28 14:48:35 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/ambari/logfeeder/filter/FilterKeyValue.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/4fe795db/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/filter/FilterKeyValue.java
----------------------------------------------------------------------
diff --git a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/filter/FilterKeyValue.java b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/filter/FilterKeyValue.java
index b04a439..237d221 100644
--- a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/filter/FilterKeyValue.java
+++ b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/filter/FilterKeyValue.java
@@ -130,14 +130,14 @@ public class FilterKeyValue extends Filter {
private String[] getNameValue(String nv) {
String splitPattern = Pattern.quote(valueSplit);
- return nv.split(splitPattern);
+ return nv.split(splitPattern, 2);
}
private void logParseError(String inputStr) {
errorMetric.value++;
String logMessageKey = this.getClass().getSimpleName() + "_PARSEERROR";
LogFeederUtil.logErrorMessageByInterval(logMessageKey, "Error parsing string. length=" + inputStr.length() + ", input=" +
- input.getShortDescription() + ". First upto 100 characters=" + StringUtils.abbreviate(inputStr, 100), null, LOG,
+ input.getShortDescription() + ". First upto 200 characters=" + StringUtils.abbreviate(inputStr, 200), null, LOG,
Level.ERROR);
}