[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15076024#comment-15076024
]
ASF GitHub Bot commented on FLINK-3115:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1479#issuecomment-168211988
Cool addition, thanks a lot!
Looking through the code, there is a lot of work done per element inserted,
like creating a hash map, an index request, etc. Is there some way to make the
work-per-element more lightweight and do more work in the initialization?
> Update Elasticsearch connector to 2.X
> -------------------------------------
>
> Key: FLINK-3115
> URL: https://issues.apache.org/jira/browse/FLINK-3115
> Project: Flink
> Issue Type: Improvement
> Components: Streaming Connectors
> Affects Versions: 0.10.0, 1.0.0, 0.10.1
> Reporter: Maximilian Michels
> Assignee: Suneel Marthi
> Fix For: 1.0.0
>
>
> The Elasticsearch connector is not up to date anymore. In version 2.X the API
> changed. The code needs to be adapted. Probably it makes sense to have a new
> class {{ElasticsearchSink2}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
