服务器上的flink表api接收器有错误java.lang.NoClassDefFoundError:无法初始化类org.elasticsearch.common.settings.Settings

Question

2022-01-04 15:58:17 java.lang.NoClassDefFoundError:无法初始化org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.createBulkProcessorBuilder(Elasticsearch7ApiCallBridge.java:80) at org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.createBulkProcessorBuilder(Elasticsearch7ApiCallBridge.java:46) at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.buildBulkProcessor(ElasticsearchSinkBase.java:379) at org的org.elasticsearch.common.settings.Settings类。apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:319) at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58) at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:442) at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:585) at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55) at org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:565) at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650) at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:540) at org.apache.flink.runtime.org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) at java.lang.Thread.run(Thread.java:748)的taskmanager.Task.doRun(Task.java:759)

1.1我将相关的jars放入flink lib 1.2，我被设置为classloader.resolve.解析-订单父-第一个1.3Flink版本是1.13.3 误差

在flink lib dir中添加elasticsearch jars

在智能思想中调试时没有错误

类加载器.解析-顺序父-优先

无论是否提供，两者都有错误 无论是否提供，两者都有错误 org.elasticsearch.action.bulk.BulkProcessor.builder(BulkProcessor.java:238)的来源

Answer 1

NoClassDefFoundError表示es版本中可能存在冲突，您可以尝试直接使用flink-sql-连接器-elasticsearch jar包。