Great! I was just thinking that, in principle, a streaming sink is an
extension of a batch one. Am I wrong?
This would avoid a lot of code duplication and would improve the overall
maintainability..
On Thu, May 11, 2017 at 4:35 AM, wyphao.2007 wrote:
> Hi Flavio, I made a PR for this : https://g
Hi Flavio, I made a PR for this : https://github.com/apache/flink/pull/3869
And it also support ActionRequestFailureHandler in DataSet's ElasticsearchSink
Best
在2017年05月09 15时30分, "Flavio Pompermaier"写道:
Just one note: I took a look at your connector and it doesn't provide any
failure handl
Just one note: I took a look at your connector and it doesn't provide any
failure handling mechanism that is very useful for us.
Maybe it could worth to add ActionRequestFailureHandler as provided now by
the current ES streaming connector and introduced by commit
https://github.com/apache/flink/com
Hi Flavio,
I don’t think there is a bridge class for this. At the moment you’ll have to
implement your own OutputFormat.
The ElasticsearchSink is a SinkFunction which is part of the DataStream API,
which generally speaking at the moment has no bridge or unification yet with
the DataSet API.
Ch
