Hi, 这个问题是一个已知问题[1]，已经在1.10.1和master修复了。但是现在1.10.1还没有发布。 你可以直接下载flink源码，用release-1.10分支编译一个。
[1] https://issues.apache.org/jira/browse/FLINK-16170 [email protected] <[email protected]> 于2020年4月16日周四 上午9:57写道： > 大家好，有哪位大神有现成的包，非常感谢！ > > flink-connector-elasticsearch7_2.11 > > ------------------------------ > > 深圳市优必选科技股份有限公司 | 平台软件部 > > 邱钺 Samuel Qiu > 手机/微信: +0086 150 1356 8368 > > Email: [email protected] > > *UBTECH Robotics **｜** www.ubtrobot.com <http://www.ubtrobot.com>* > > 广东省深圳市南山区平山路鸿莱科创楼13栋3楼优必选 > > > *From:* [email protected] > *Date:* 2020-04-15 17:37 > *To:* user-zh <[email protected]> > *Subject:* flink-sql-connector-elasticsearch7_2.11-1.10.0.jar > 在提交job后，发现不成功，这个问题要怎么解决？ > 版本：Flink1.10.0 elasticsearch:7.6.0 > > 看了源码，确实是没这个类的： > > Caused by: java.lang.NoClassDefFoundError: > org/apache/flink/elasticsearch7/shaded/org/elasticsearch/script/mustache/ > SearchTemplateRequest > at org.apache.flink.streaming.connectors.elasticsearch7. > Elasticsearch7ApiCallBridge.createClient(Elasticsearch7ApiCallBridge.java: > 76) > at org.apache.flink.streaming.connectors.elasticsearch7. > Elasticsearch7ApiCallBridge.createClient(Elasticsearch7ApiCallBridge.java: > 48) > at org.apache.flink.streaming.connectors.elasticsearch. > ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:299) > 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 > .initializeStateAndOpen(StreamTask.java:1007) > at org.apache.flink.streaming.runtime.tasks.StreamTask > .lambda$beforeInvoke$0(StreamTask.java:454) > at org.apache.flink.streaming.runtime.tasks. > StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing( > StreamTaskActionExecutor.java:94) > at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke( > StreamTask.java:449) > at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke( > StreamTask.java:461) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.lang.ClassNotFoundException: > org.apache.flink.elasticsearch7.shaded.org.elasticsearch.script.mustache. > SearchTemplateRequest > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > ... 14 more > > > 谢谢！ > > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: [email protected]; [email protected]
