Repository: ambari Updated Branches: refs/heads/branch-2.6 812ded6ca -> 4fe795dba
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-2.6 Commit: 4fe795dba0a5451159c0afa8cc273b181887dd10 Parents: 812ded6 Author: Oliver Szabo <[email protected]> Authored: Tue Nov 28 14:48:35 2017 +0100 Committer: Oliver Szabo <[email protected]> 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); }
