[jira] [Commented] (FLINK-6502) Add support ElasticsearchSink for DataSet

[ASF GitHub Bot (JIRA)]

    [ 
https://issues.apache.org/jira/browse/FLINK-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015470#comment-16015470
 ] 

ASF GitHub Bot commented on FLINK-6502:
---------------------------------------

Github user 397090770 commented on the issue:

    https://github.com/apache/flink/pull/3869
  
    @tzulitai Thank you for your review very much.  The current structuring of 
the ES output format as follow:
    
![elasticsearch_flink](https://cloud.githubusercontent.com/assets/5170878/26194858/69c36264-3bec-11e7-9f52-db329414dae4.png)
    as you can see, both `ElasticsearchSinkBase` for batch and 
`ElasticsearchSinkBase` for stream need `ActionRequestFailureHandler`, 
`RequestIndexer` ect, so I move those class to a different package, and do you 
have any suggestions? Thank you.


> Add support ElasticsearchSink for DataSet
> -----------------------------------------
>
>                 Key: FLINK-6502
>                 URL: https://issues.apache.org/jira/browse/FLINK-6502
>             Project: Flink
>          Issue Type: New Feature
>          Components: DataSet API
>    Affects Versions: 1.2.1
>            Reporter: wyp
>
> Currently, Flink only support writing data in DataStream to ElasticSearch 
> through {{ElasticsearchSink}}, We should be able to writing data in DataSet 
> to ElasticSearch too. see 
> [http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ElasticsearchSink-on-DataSet-td12980.html]



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)