[
https://issues.apache.org/jira/browse/STORM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jungtaek Lim updated STORM-2379:
--------------------------------
Summary: [storm-elasticsearch] switch ES client to Java REST API (was:
still refers 1.6 elastic)
> [storm-elasticsearch] switch ES client to Java REST API
> -------------------------------------------------------
>
> Key: STORM-2379
> URL: https://issues.apache.org/jira/browse/STORM-2379
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-elasticsearch
> Affects Versions: 1.0.1, 1.0.2, 1.0.3
> Environment: storm 1.0.x
> elastic 5.0.0 and higher
> Reporter: Sree Vaddi
> Assignee: Heather McCartney
> Fix For: 2.0.0
>
> Time Spent: 1h 40m
> Remaining Estimate: 0h
>
> following documentation:
> https://storm.apache.org/releases/1.0.1/storm-elasticsearch.html
> https://github.com/apache/storm/blob/master/external/storm-elasticsearch/pom.xml#L40
> this causes errors while writing to elastic 5.x
> {code:language=java}
> java.lang.NoClassDefFoundError: org/elasticsearch/common/base/Preconditions
> at
> org.apache.storm.elasticsearch.common.EsConfig.<init>(EsConfig.java:62)
> ~[storm-elasticsearch-1.0.2.jar:1.0.2]
> at
> org.apache.storm.elasticsearch.common.EsConfig.<init>(EsConfig.java:49)
> ~[storm-elasticsearch-1.0.2.jar:1.0.2]
> Caused by: java.lang.ClassNotFoundException:
> org.elasticsearch.common.base.Preconditions
> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
> ~[?:1.8.0_112]
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_112]
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
> ~[?:1.8.0_112]
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_112]
> 261538 [elasticsearch[Ringleader][generic][T#2]] INFO o.e.c.transport -
> [Ringleader] failed to get node info for
> [#transport#-1][svaddi][inet[localhost/127.0.0.1:9200]], disconnecting...
> org.elasticsearch.transport.ReceiveTimeoutTransportException:
> [][inet[localhost/127.0.0.1:9200]][cluster:monitor/nodes/info] request_id
> [26] timed out after [5005ms]
> at
> org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:529)
> ~[elasticsearch-1.6.0.jar:?]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [?:1.8.0_112]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [?:1.8.0_112]
> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_112]
> {code}
> elastic logs:
> {code:language=java}
> [2017-02-23T15:47:04,487][WARN ][o.e.t.n.Netty4Transport ] [Qt9qlNV]
> exception caught on transport layer [[id: 0x8f15e875, L:/127.0.0.1:9300 -
> R:/127.0.0.1:52031]], closing connection
> java.lang.IllegalStateException: Received message from unsupported version:
> [1.0.0] minimal compatible version is: [5.0.0]
> at
> org.elasticsearch.transport.TcpTransport.messageReceived(TcpTransport.java:1199)
> ~[elasticsearch-5.0.0.jar:5.0.0]
> at
> org.elasticsearch.transport.netty4.Netty4MessageChannelHandler.channelRead(Netty4MessageChannelHandler.java:74)
> ~[transport-netty4-5.0.0.jar:5.0.0]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
> [netty-codec-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:280)
> [netty-codec-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:396)
> [netty-codec-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248)
> [netty-codec-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:513)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:467)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
> [netty-transport-4.1.5.Final.jar:4.1.5.Final]
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
> [netty-common-4.1.5.Final.jar:4.1.5.Final]
> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
