[FLUME-3192] It seems that flume-ng-elasticsearch-sink has an wrong spell

• Type: Question
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.7.0, 1.8.0
• Component/s: Sinks+Sources
• Assignee: Unassigned
• Reporter: youxianqin
• Created: 07/Nov/17 07:12
• Updated: 07/Nov/17 07:12

Description

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)

// 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

I think the line 317 should be like that:

    indexnameBuilderContext .putAll(
            context.getSubProperties(INDEX_NAME_BUILDER_PREFIX));

is it a wrong spell or i misunderstand the code
sorry for my poor english