flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X
Date Fri, 18 Mar 2016 10:56:33 GMT

    [ 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)

Mime
View raw message