Re: ElasticsearchSink Serialization Error

2017-04-28 Thread Aljoscha Krettek
Hi, ResultIndexRequestBuilder is a non-static inner class. This means it has a pointer to the enclosing instance. If you make it a static inner class your code should work. Best, Aljoscha > On 28. Apr 2017, at 04:57, Vijay Srinivasaraghavan > wrote: > > Hello, > > I am seeing below error whe

ElasticsearchSink Serialization Error

2017-04-27 Thread Vijay Srinivasaraghavan
Hello, I am seeing below error when I try to use ElasticsearchSink. It complains about serialization and looks like it is leading to "IndexRequestBuilder" implementation. I have tried the suggestion as mentioned in  http://stackoverflow.com/questions/33246864/elasticsearch-sink-seralizability  (c