youxianqin created FLUME-3192: --------------------------------- Summary: It seems that flume-ng-elasticsearch-sink has an wrong spell Key: FLUME-3192 URL: https://issues.apache.org/jira/browse/FLUME-3192 Project: Flume Issue Type: Question Components: Sinks+Sources Affects Versions: 1.7.0, 1.8.0 Reporter: youxianqin
there is some code from flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java(line 311 to line 317) {code:java} // Some comments here String indexNameBuilderClass = DEFAULT_INDEX_NAME_BUILDER_CLASS; if (StringUtils.isNotBlank(context.getString(INDEX_NAME_BUILDER))) { indexNameBuilderClass = context.getString(INDEX_NAME_BUILDER); } Context indexnameBuilderContext = new Context(); serializerContext.putAll(context.getSubProperties(INDEX_NAME_BUILDER_PREFIX)); //line 317 {code} I think the line 317 should be like that: {code:java} indexnameBuilderContext .putAll( context.getSubProperties(INDEX_NAME_BUILDER_PREFIX)); {code} is it a wrong spell or i misunderstand the code sorry for my poor english -- This message was sent by Atlassian JIRA (v6.4.14#64029)