[
https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16420326#comment-16420326
]
ASF GitHub Bot commented on FLINK-8989:
---------------------------------------
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5761
I found an issue, I tried find it out but it seems useless.
For elasticsearch5sink, I can run directly with the following command with
flink cluster setup and elasticsearch5 cluster set up also without error.
**[Flink cluster and ES cluster setup by manually.]**
```
$FLINK_DIR/bin/flink run -p 1
projects/flink/flink-end-to-end-tests/flink-elasticsearch5-test/target/Elasticsearch5SinkExample.jar
--index index --type type
```
But when I change it to bash scripts to set up flink cluster and es5
cluster. Although it can be written to elasticsearch5 without error[we can
see **Elasticsearch end to end test pass** in the following message]. In the
end, it will throw an exception.
```
/Users/zhangminglei/projects/flink/flink-end-to-end-tests/test-scripts/../flink-elasticsearch5-test/target/Elasticsearch5SinkExample.jar
Starting execution of program
Program execution finished
Job with JobID 2774e793a167a6bfba07031948fb5b14 has finished.
Job Runtime: 6564 ms
% Total % Received % Xferd Average Speed Time Time Time
Current
Dload Upload Total Spent Left
Speed
100 4189 100 4189 0 0 19737 0 --:--:-- --:--:-- --:--:--
19759
Elasticsearch end to end test pass.
Stopping taskexecutor daemon (pid: 86784) on host
zhangmingleideMacBook-Pro.local.
Stopping standalonesession daemon (pid: 86475) on host
zhangmingleideMacBook-Pro.local.
Found non-empty .out files:
Exception in thread "Thread-6" java.lang.NoClassDefFoundError:
org/apache/flink/streaming/connectors/elasticsearch5/shaded/org/jboss/netty/channel/socket/nio/NioWorker$RegisterTask
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioWorker.createRegisterTask(NioWorker.java:118)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.AbstractNioSelector.register(AbstractNioSelector.java:104)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioWorker.register(NioWorker.java:36)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:157)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:79)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioWorker$RegisterTask
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at
org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:120)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 13 more
One or more tests FAILED.
```
> End-to-end test: ElasticSearch connector
> ----------------------------------------
>
> Key: FLINK-8989
> URL: https://issues.apache.org/jira/browse/FLINK-8989
> Project: Flink
> Issue Type: Sub-task
> Components: ElasticSearch Connector, Tests
> Reporter: Till Rohrmann
> Assignee: mingleizhang
> Priority: Major
>
> Similar to FLINK-8988 we should add a end-to-end test which tests the
> {{ElasticSearch}} connector. We should run against all three supported
> ElasticSearch versions: 1.x, 2.x and 5.x.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
