flink-1.11 sql写ES6问题

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

flink-1.11 sql写ES6问题

酷酷的浑蛋
Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.RestClientBuilder
Flink sql 写入ES:总是报上面的错误,我检查了依赖并没有冲突这个类啊,而且我解压了jar,里面是有这个类的啊



Reply | Threaded
Open this post in threaded view
|

Re: flink-1.11 sql写ES6问题

Danny Chan
Es connector 的包放到哪个目录下了 ?

Best,
Danny Chan
在 2020年9月2日 +0800 PM3:38,酷酷的浑蛋 <[hidden email]>,写道:
> Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.RestClientBuilder
> Flink sql 写入ES:总是报上面的错误,我检查了依赖并没有冲突这个类啊,而且我解压了jar,里面是有这个类的啊
>
>
>
Reply | Threaded
Open this post in threaded view
|

Re: flink-1.11 sql写ES6问题

Storm☀️
In reply to this post by 酷酷的浑蛋
可能是jar包冲突。



--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

回复: flink-1.11 sql写ES6问题

酷酷的浑蛋
In reply to this post by Danny Chan
放到flink/lib下了




在2020年09月2日 16:52,Danny Chan<[hidden email]> 写道:
Es connector 的包放到哪个目录下了 ?

Best,
Danny Chan
在 2020年9月2日 +0800 PM3:38,酷酷的浑蛋 <[hidden email]>,写道:
Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.RestClientBuilder
Flink sql 写入ES:总是报上面的错误,我检查了依赖并没有冲突这个类啊,而且我解压了jar,里面是有这个类的啊