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 >
