缺少class
来源:11-14 统计分析数据写入ES并通过Kibana展示出来
passmefive
2019-06-14
PK哥,,我跟着你的视频里面写的代码,怎么你的不报错,我就如下错误呢,应该如何解决啊
Caused by: java.lang.NoClassDefFoundError: org/apache/http/client/config/RequestConfig
at org.elasticsearch.client.RestClientBuilder.createHttpClient(RestClientBuilder.java:196)
at org.elasticsearch.client.RestClientBuilder.access$000(RestClientBuilder.java:42)
at org.elasticsearch.client.RestClientBuilder$1.run(RestClientBuilder.java:186)
at org.elasticsearch.client.RestClientBuilder$1.run(RestClientBuilder.java:183)
at java.security.AccessController.doPrivileged(Native Method)
at org.elasticsearch.client.RestClientBuilder.build(RestClientBuilder.java:183)
at org.elasticsearch.client.RestHighLevelClient.(RestHighLevelClient.java:204)
at org.elasticsearch.client.RestHighLevelClient.(RestHighLevelClient.java:196)
at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.createClient(Elasticsearch6ApiCallBridge.java:75)
at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.createClient(Elasticsearch6ApiCallBridge.java:47)
at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:296)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
at org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
1回答
-
Michael_PK
2019-06-14
需要添加dependency:flink-connector-elasticsearch
00
相似问题