[GitHub] flink issue #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to end tes...

[zhangminglei <gi...@git.apache.org>]

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.
    ```


---