[
https://issues.apache.org/jira/browse/NIFI-4904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16473292#comment-16473292
]
Mike Thomsen commented on NIFI-4904:
------------------------------------
The transport protocol is being deprecated in favor of HTTP/REST by Elastic, so
new ES functionality is being steadily developed around the official client
APIs for REST.
[Source|https://www.elastic.co/guide/en/elasticsearch/client/java-api/master/transport-client.html]
> PutElasticSearch5 should support higher than elasticsearch 5.0.0
> ----------------------------------------------------------------
>
> Key: NIFI-4904
> URL: https://issues.apache.org/jira/browse/NIFI-4904
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Extensions
> Affects Versions: 1.5.0
> Environment: Ubuntu
> Reporter: Dye357
> Priority: Trivial
> Original Estimate: 2h
> Remaining Estimate: 2h
>
> Currently the PutElasticSearch5 component is using the following transport
> artifact
> <dependency>
> <groupId>org.elasticsearch.client</groupId>
> <artifactId>transport</artifactId>
> <version>${es.version}</version>
> </dependency>
> Where es.version is 5.0.1. Upgrading to the highest 5.x dependency would
> enable this component to be compatible with later 5.x versions of elastic
> search as well as early versions of elastic search 6.x.
> Here is Nifi 1.5.0 connecting to ES 6.2.1 on port 9300:
> [2018-02-23T01:41:04,162][WARN ][o.e.t.n.Netty4Transport ] [uQSW8O8]
> exception caught on transport layer
> [NettyTcpChannel\{localAddress=/127.0.0.1:9300,
> remoteAddress=/127.0.0.1:57457}], closing connection
> java.lang.IllegalStateException: Received message from unsupported version:
> [5.0.0] minimal compatible version is: [5.6.0]
> at
> org.elasticsearch.transport.TcpTransport.ensureVersionCompatibility(TcpTransport.java:1430)
> ~[elasticsearch-6.2.1.jar:6.2.1]
> at
> org.elasticsearch.transport.TcpTransport.messageReceived(TcpTransport.java:1377)
> ~[elasticsearch-6.2.1.jar:6.2.1]
> at
> org.elasticsearch.transport.netty4.Netty4MessageChannelHandler.channelRead(Netty4MessageChannelHandler.java:64)
> ~[transport-netty4-6.2.1.jar:6.2.1]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
> [netty-codec-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:297)
> [netty-codec-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:413)
> [netty-codec-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
> [netty-codec-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.handler.logging.LoggingHandler.channelRead(LoggingHandler.java:241)
> [netty-handler-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:545)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:499)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
> [netty-transport-4.1.16.Final.jar:4.1.16.Final]
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
> [netty-common-4.1.16.Final.jar:4.1.16.Final]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_151]
> Proposed solution(s): bump the es.version to a higher 5.x version and/or
> create PutElasticSearch6.
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
