.endObject()
> .endObject()
> .endObject();
> }
> catch ( IOException e )
> {
> e.printStackTrace();
> }
>
> return mapping;
> }
>
>
>
>
>
switched to FAILED
>
>
> We try to add mapping request to elastic search. We cannot access to
> client attribute (it is private) in elasticsearch class.
>
>
> Is there any way to overcome this problem.
>
>
> Thanks,
>
>
> Ozan
>
>
>
> __________
Hi Ozan,
I'm not super experienced with Flink's elasticsearch connector, but could
you post the complete stack trace to figure out where the problem comes
from?
I've also pulled in Aljoscha, the original author of the elasticsearch
sink. Maybe he can give you a detailed answer.
Cheers,
Till
On
