Also, the ES version I'm using is 5.6.7 Jayant
On Thu, Jan 9, 2020 at 10:39 AM Jayant Ameta <wittyam...@gmail.com> wrote: > Hi, > The elastic connector is packaged in the uber jar that is submitted. There > is only 1 version of the connector: > flink-connector-elasticsearch5_2.11:1.7.1 > I'm using Flink 1.7.1 > > I couldn't figure out whether this error causes the job to fail, or > whether I see this error when the job is restarting after some other > failure. > But, the occurrence of this error and job restarts is correlated. > > > Jayant Ameta > > > On Wed, Jan 8, 2020 at 6:47 PM Arvid Heise <ar...@ververica.com> wrote: > >> Hi Jayant, >> >> if you only see it sometimes that indicates that you have it in two >> different versions of the connectors where class loader order is >> non-deterministic. Could you post the classpath? >> >> Btw, it's always good to add which Flink version you use. >> >> Best, >> >> Arvid >> >> On Wed, Jan 8, 2020 at 12:20 PM Jayant Ameta <wittyam...@gmail.com> >> wrote: >> >>> Hi, >>> I see the following error sometimes on my flink job, even though the >>> class is present in my uber jar. >>> >>> java.lang.NoClassDefFoundError: >>> org/apache/flink/streaming/connectors/elasticsearch5/shaded/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink$1 >>> at >>> org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:111) >>> ... 17 common frames omitted Wrapped by: >>> org.elasticsearch.ElasticsearchException: java.lang.NoClassDefFoundError: >>> org/apache/flink/streaming/connectors/elasticsearch5/shaded/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink$1 >>> at >>> org.elasticsearch.transport.netty3.Netty3Transport.exceptionCaught(Netty3Transport.java:325) >>> at >>> org.elasticsearch.transport.netty3.Netty3MessageChannelHandler.exceptionCaught(Netty3MessageChannelHandler.java:83) >>> at >>> org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112) >>> at >>> org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) >>> at >>> org.apache.flink.streaming.connectors.elasticsearch5.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) >>> ... 23 frames truncated >>> >>> >>> Jayant >>> >>
