
问题背景
//flink官方提供的链接org.apache.flink flink-connector-elasticsearch7_2.11${flink.version}
我想再在别的功能算子中使用es 于是我引入了下面这个jar包
org.elasticsearch.client elasticsearch-rest-high-level-client7.5.1
报错:没有org.elasticsearch.common.unit.Timevalue;
问题原因
1、在flink-connector-elasticsearch7_2.11中已经包含了 elasticsearch-rest-high-level-client和org.elasticsearch.clien,
2、在flink-connector-elasticsearch7_2.11中的elasticsearch-rest-high-level-client包含了 unit/Timevalue
但是 如果单独引入elasticsearch-rest-high-level-client中,他没有unit这个包,并且会覆盖
flink-connector-elasticsearch7_2.11中的elasticsearch-rest-high-level-client中的包
所以会报错
解决方案
化蛇填足了,不要引入其他jar, flink-connector-elasticsearch7_2.11中足以。
//flink官方提供的链接org.apache.flink flink-connector-elasticsearch7_2.11${flink.version}
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)