[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15201311#comment-15201311
]
ASF GitHub Bot commented on FLINK-3115:
---------------------------------------
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1792#issuecomment-198305510
I tried running the connector, but I got the following error:
```
11:53:19,133 INFO org.apache.flink.runtime.taskmanager.Task
- Source: Out of order data generator -> (Flat Map, Sink: Unnamed) (1/1)
switched to FAILED with exception.
java.lang.IllegalStateException: failed to load bundle
[file:/home/robert/flink-workdir/elasticsearch/elasticsearch-2.2.1/modules/lang-groovy/lang-groovy-2.2.1.jar,
file:/home/robert/flink-workdir/elasticsearch/elasticsearch-2.2.1/modules/lang-groovy/groovy-all-2.4.4-indy.jar]
due to jar hell
at
org.elasticsearch.plugins.PluginsService.loadBundles(PluginsService.java:421)
at
org.elasticsearch.plugins.PluginsService.<init>(PluginsService.java:115)
at org.elasticsearch.node.Node.<init>(Node.java:146)
at org.elasticsearch.node.Node.<init>(Node.java:128)
at org.elasticsearch.node.NodeBuilder.build(NodeBuilder.java:145)
at org.elasticsearch.node.NodeBuilder.node(NodeBuilder.java:152)
at
org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.open(ElasticsearchSink.java:199)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38)
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:317)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:215)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:564)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalStateException: jar hell!
class: org.apache.flink.shaded.com.google.common.annotations.Beta
jar1:
/home/robert/.m2/repository/org/apache/flink/flink-java/1.1-SNAPSHOT/flink-java-1.1-SNAPSHOT.jar
jar2:
/home/robert/.m2/repository/org/apache/flink/flink-core/1.1-SNAPSHOT/flink-core-1.1-SNAPSHOT.jar
at org.elasticsearch.bootstrap.JarHell.checkClass(JarHell.java:280)
at org.elasticsearch.bootstrap.JarHell.checkJarHell(JarHell.java:186)
at
org.elasticsearch.plugins.PluginsService.loadBundles(PluginsService.java:419)
... 12 more
```
How did you resolve that issue?
> Update Elasticsearch connector to 2.X
> -------------------------------------
>
> Key: FLINK-3115
> URL: https://issues.apache.org/jira/browse/FLINK-3115
> Project: Flink
> Issue Type: Improvement
> Components: Streaming Connectors
> Affects Versions: 0.10.0, 1.0.0, 0.10.1
> Reporter: Maximilian Michels
> Assignee: Suneel Marthi
> Fix For: 1.0.1
>
>
> The Elasticsearch connector is not up to date anymore. In version 2.X the API
> changed. The code needs to be adapted. Probably it makes sense to have a new
> class {{ElasticsearchSink2}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
