赞
踩
问题背景
//flink官方提供的链接
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-elasticsearch7_2.11</artifactId>
<version>${flink.version}</version>
</dependency>
我想再在别的功能算子中使用es 于是我引入了下面这个jar包
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.5.1</version>
</dependency>
报错:没有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官方提供的链接
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-elasticsearch7_2.11</artifactId>
<version>${flink.version}</version>
</dependency>
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。