21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Starting task 5.0 in stage 76.0 (TID 1333, ip-172-31-34-9.ec2.internal, executor 1, partition 5, PROCESS_LOCAL, 7325 bytes) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Finished task 3.0 in stage 76.0 (TID 1331) in 418 ms on ip-172-31-34-9.ec2.internal (executor 1) (4/26) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Starting task 3.0 in stage 69.0 (TID 1102, ip-172-31-38-75.ec2.internal, executor 1, partition 3, RACK_LOCAL, 11883 bytes) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Finished task 2.0 in stage 69.0 (TID 1101) in 895 ms on ip-172-31-38-75.ec2.internal (executor 1) (3/6) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Finished task 24.0 in stage 10.0 (TID 397) in 11437 ms on ip-172-31-35-205.ec2.internal (executor 2) (21/29) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Starting task 150.0 in stage 68.0 (TID 1702, ip-172-31-47-125.ec2.internal, executor 1, partition 150, PROCESS_LOCAL, 7325 bytes) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Finished task 148.0 in stage 68.0 (TID 1700) in 966 ms on ip-172-31-47-125.ec2.internal (executor 1) (149/334) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Starting task 6.0 in stage 76.0 (TID 1334, ip-172-31-34-9.ec2.internal, executor 1, partition 6, PROCESS_LOCAL, 7325 bytes) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO TaskSetManager: Finished task 4.0 in stage 76.0 (TID 1332) in 350 ms on ip-172-31-34-9.ec2.internal (executor 1) (5/26) 21/02/05 03:17:10 INFO LineBufferedStream: 21/02/05 03:17:10 INFO Client: Uploading resource file:/usr/lib/livy/rsc-jars/livy-thriftserver-session-0.7.0-incubating.jar -> hdfs://ip-172-31-43-108.ec2.internal:8020/user/livy/.sparkStaging/application_1612315048457_2690/livy...skipping... java.lang.IllegalStateException: failed to create a child event loop at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:88) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:58) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:47) at io.netty.channel.MultithreadEventLoopGroup.(MultithreadEventLoopGroup.java:59) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:77) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:72) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:59) at org.apache.livy.rsc.RSCClient.(RSCClient.java:81) at org.apache.livy.rsc.RSCClientFactory.createClient(RSCClientFactory.java:76) at org.apache.livy.LivyClientBuilder.build(LivyClientBuilder.java:130) at org.apache.livy.server.interactive.InteractiveSession$.$anonfun$create$1(InteractiveSession.scala:111) at scala.Option.orElse(Option.scala:447) at org.apache.livy.server.interactive.InteractiveSession$.create(InteractiveSession.scala:81) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:55) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:40) at org.apache.livy.server.SessionServlet.$anonfun$new$16(SessionServlet.scala:139) at org.scalatra.ScalatraBase.liftAction(ScalatraBase.scala:280) at org.scalatra.ScalatraBase.$anonfun$invoke$1(ScalatraBase.scala:274) at org.scalatra.ApiFormats.withRouteMultiParams(ApiFormats.scala:183) at org.scalatra.ApiFormats.withRouteMultiParams$(ApiFormats.scala:169) at org.apache.livy.server.JsonServlet.withRouteMultiParams(JsonServlet.scala:39) at org.scalatra.ScalatraBase.invoke(ScalatraBase.scala:273) at org.scalatra.ScalatraBase.invoke$(ScalatraBase.scala:272) at org.apache.livy.server.JsonServlet.invoke(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$runRoutes$3(ScalatraBase.scala:248) at scala.Option.flatMap(Option.scala:271) at org.scalatra.ScalatraBase.$anonfun$runRoutes$1(ScalatraBase.scala:246) at scala.collection.immutable.Stream.flatMap(Stream.scala:493) at org.scalatra.ScalatraBase.runRoutes(ScalatraBase.scala:245) at org.scalatra.ScalatraBase.runRoutes$(ScalatraBase.scala:243) at org.apache.livy.server.JsonServlet.runRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.runActions$1(ScalatraBase.scala:169) at org.scalatra.ScalatraBase.$anonfun$executeRoutes$6(ScalatraBase.scala:181) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at org.scalatra.ScalatraBase.cradleHalt(ScalatraBase.scala:199) at org.scalatra.ScalatraBase.executeRoutes(ScalatraBase.scala:181) at org.scalatra.ScalatraBase.executeRoutes$(ScalatraBase.scala:150) at org.apache.livy.server.JsonServlet.executeRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$handle$1(ScalatraBase.scala:123) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withResponse(DynamicScope.scala:79) at org.scalatra.DynamicScope.withResponse$(DynamicScope.scala:77) at org.apache.livy.server.JsonServlet.withResponse(JsonServlet.scala:39) at org.scalatra.DynamicScope.$anonfun$withRequestResponse$1(DynamicScope.scala:59) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withRequest(DynamicScope.scala:70) at org.scalatra.DynamicScope.withRequest$(DynamicScope.scala:68) at org.apache.livy.server.JsonServlet.withRequest(JsonServlet.scala:39) at org.scalatra.DynamicScope.withRequestResponse(DynamicScope.scala:58) at org.scalatra.DynamicScope.withRequestResponse$(DynamicScope.scala:56) at org.apache.livy.server.JsonServlet.withRequestResponse(JsonServlet.scala:39) at org.scalatra.ScalatraBase.handle(ScalatraBase.scala:123) at org.scalatra.ScalatraBase.handle$(ScalatraBase.scala:119) at org.apache.livy.server.JsonServlet.org$scalatra$servlet$ServletBase$$super$handle(JsonServlet.scala:39) at org.scalatra.servlet.ServletBase.handle(ServletBase.scala:53) at org.scalatra.servlet.ServletBase.handle$(ServletBase.scala:46) at org.apache.livy.server.SessionServlet.org$scalatra$MethodOverride$$super$handle(SessionServlet.scala:45) at org.scalatra.MethodOverride.handle(MethodOverride.scala:35) ...skipping... 21/02/05 14:15:57 INFO LineBufferedStream: java.lang.IllegalArgumentException: Unexpected client ID '40f2d9b7-6460-45b1-9521-6a92ff733766' in SASL handshake. 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.Utils.checkArgument(Utils.java:42) 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.rpc.RpcServer$SaslServerHandler.update(RpcServer.java:288) 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:61) 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:36) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:295) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:103) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 21/02/05 14:15:57 INFO LineBufferedStream: at java.lang.Thread.run(Thread.java:748) 21/02/05 14:15:57 INFO LineBufferedStream: 21/02/05 14:15:57 WARN DefaultChannelPipeline: An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception. 21/02/05 14:15:57 INFO LineBufferedStream: java.lang.IllegalArgumentException: Unexpected client ID '40f2d9b7-6460-45b1-9521-6a92ff733766' in SASL handshake. 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.Utils.checkArgument(Utils.java:42) 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.rpc.RpcServer$SaslServerHandler.update(RpcServer.java:288) 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:61) 21/02/05 14:15:57 INFO LineBufferedStream: at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:36) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:295) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:103) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) 21/02/05 14:15:57 INFO LineBufferedStream: at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 21/02/05 14:15:57 INFO LineBufferedStream: at java.lang.Thread.run(Thread.java:748) 21/02/05 14:15:58 WARN ContextLauncher: Child process exited with code 1. 21/02/05 14:15:58 ERROR rejectedExecution: Failed to submit a listener notification task. Event loop shut down? java.util.concurrent.RejectedExecutionException: event executor terminated at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:821) at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:327) at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:320) at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:746) at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:760) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:428) at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:122) at org.apache.livy.rsc.ContextLauncher$ChildProcess.fail(ContextLauncher.java:417) at org.apache.livy.rsc.ContextLauncher$ChildProcess.access$1100(ContextLauncher.java:369) at org.apache.livy.rsc.ContextLauncher$ChildProcess$1.run(ContextLauncher.java:400) at org.apache.livy.rsc.ContextLauncher$ChildProcess$2.run(ContextLauncher.java:451) at java.lang.Thread.run(Thread.java:748) 21/02/05 14:15:58 INFO LineBufferedStream: 21/02/05 14:15:58 INFO Client: Application report for application_1612315048457_3258 (state: ACCEPTED) 21/02/05 14:15:59 INFO LineBufferedStream: 21/02/05 14:15:59 INFO Client: Application report for application_1612315048457_3258 (state: ACCEPTED) 21/02/05 14:15:59 INFO LineBufferedStream: 21/02/05 14:15:59 INFO RSCDriver: Connecting to: ip-172-31-43-108.ec2.internal:10000 21/02/05 14:15:59 INFO LineBufferedStream: 21/02/05 14:15:59 INFO RSCDriver: Starting RPC server... 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO Client: Application report for application_1612315048457_3258 (state: ACCEPTED) 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO TaskSetManager: Finished task 0.0 in stage 10.0 (TID 196) in 14208 ms on ip-172-31-34-9.ec2.internal (executor 1) (3/3) 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO YarnScheduler: Removed TaskSet 10.0, whose tasks have all completed, from pool 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: ShuffleMapStage 10 (parquet at Compactor.scala:55) finished in 14.252 s 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: looking for newly runnable stages 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: running: Set() 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: waiting: Set() 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: failed: Set() 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO RpcServer: Connected to the port 10005 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 WARN RSCConf: Your hostname, ip-172-31-43-108.ec2.internal, resolves to a loopback address, but we couldn't find any external IP address! 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 WARN RSCConf: Set livy.rsc.rpc.server.address if you need to bind to another address. 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO ShufflePartitionsUtil: For shuffle(2), advisory target size: 67108864, actual target size 49846951. 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: Registering RDD 31 (parquet at Compactor.scala:55) as input to shuffle 3 21/02/05 14:16:00 INFO LineBufferedStream: 21/02/05 14:16:00 INFO DAGScheduler: Got map stage job 8 (parquet at Compactor.scala:55) with 26 output partitions ...skipping... java.lang.IllegalStateException: failed to create a child event loop at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:88) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:58) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:47) at io.netty.channel.MultithreadEventLoopGroup.(MultithreadEventLoopGroup.java:59) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:77) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:72) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:59) at org.apache.livy.rsc.RSCClient.(RSCClient.java:81) at org.apache.livy.rsc.RSCClientFactory.createClient(RSCClientFactory.java:76) at org.apache.livy.LivyClientBuilder.build(LivyClientBuilder.java:130) at org.apache.livy.server.interactive.InteractiveSession$.$anonfun$create$1(InteractiveSession.scala:111) at scala.Option.orElse(Option.scala:447) at org.apache.livy.server.interactive.InteractiveSession$.create(InteractiveSession.scala:81) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:55) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:40) at org.apache.livy.server.SessionServlet.$anonfun$new$16(SessionServlet.scala:139) at org.scalatra.ScalatraBase.liftAction(ScalatraBase.scala:280) at org.scalatra.ScalatraBase.$anonfun$invoke$1(ScalatraBase.scala:274) at org.scalatra.ApiFormats.withRouteMultiParams(ApiFormats.scala:183) at org.scalatra.ApiFormats.withRouteMultiParams$(ApiFormats.scala:169) at org.apache.livy.server.JsonServlet.withRouteMultiParams(JsonServlet.scala:39) at org.scalatra.ScalatraBase.invoke(ScalatraBase.scala:273) at org.scalatra.ScalatraBase.invoke$(ScalatraBase.scala:272) at org.apache.livy.server.JsonServlet.invoke(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$runRoutes$3(ScalatraBase.scala:248) at scala.Option.flatMap(Option.scala:271) at org.scalatra.ScalatraBase.$anonfun$runRoutes$1(ScalatraBase.scala:246) at scala.collection.immutable.Stream.flatMap(Stream.scala:493) at org.scalatra.ScalatraBase.runRoutes(ScalatraBase.scala:245) at org.scalatra.ScalatraBase.runRoutes$(ScalatraBase.scala:243) at org.apache.livy.server.JsonServlet.runRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.runActions$1(ScalatraBase.scala:169) at org.scalatra.ScalatraBase.$anonfun$executeRoutes$6(ScalatraBase.scala:181) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at org.scalatra.ScalatraBase.cradleHalt(ScalatraBase.scala:199) at org.scalatra.ScalatraBase.executeRoutes(ScalatraBase.scala:181) at org.scalatra.ScalatraBase.executeRoutes$(ScalatraBase.scala:150) at org.apache.livy.server.JsonServlet.executeRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$handle$1(ScalatraBase.scala:123) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withResponse(DynamicScope.scala:79) at org.scalatra.DynamicScope.withResponse$(DynamicScope.scala:77) at org.apache.livy.server.JsonServlet.withResponse(JsonServlet.scala:39) at org.scalatra.DynamicScope.$anonfun$withRequestResponse$1(DynamicScope.scala:59) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withRequest(DynamicScope.scala:70) at org.scalatra.DynamicScope.withRequest$(DynamicScope.scala:68) at org.apache.livy.server.JsonServlet.withRequest(JsonServlet.scala:39) at org.scalatra.DynamicScope.withRequestResponse(DynamicScope.scala:58) at org.scalatra.DynamicScope.withRequestResponse$(DynamicScope.scala:56) at org.apache.livy.server.JsonServlet.withRequestResponse(JsonServlet.scala:39) at org.scalatra.ScalatraBase.handle(ScalatraBase.scala:123) at org.scalatra.ScalatraBase.handle$(ScalatraBase.scala:119) at org.apache.livy.server.JsonServlet.org$scalatra$servlet$ServletBase$$super$handle(JsonServlet.scala:39) at org.scalatra.servlet.ServletBase.handle(ServletBase.scala:53) at org.scalatra.servlet.ServletBase.handle$(ServletBase.scala:46) at org.apache.livy.server.SessionServlet.org$scalatra$MethodOverride$$super$handle(SessionServlet.scala:45) at org.scalatra.MethodOverride.handle(MethodOverride.scala:35) ...skipping... java.lang.IllegalStateException: failed to create a child event loop at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:88) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:58) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:47) at io.netty.channel.MultithreadEventLoopGroup.(MultithreadEventLoopGroup.java:59) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:77) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:72) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:59) at org.apache.livy.rsc.RSCClient.(RSCClient.java:81) at org.apache.livy.rsc.RSCClientFactory.createClient(RSCClientFactory.java:76) at org.apache.livy.LivyClientBuilder.build(LivyClientBuilder.java:130) at org.apache.livy.server.interactive.InteractiveSession$.$anonfun$create$1(InteractiveSession.scala:111) at scala.Option.orElse(Option.scala:447) at org.apache.livy.server.interactive.InteractiveSession$.create(InteractiveSession.scala:81) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:55) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:40) at org.apache.livy.server.SessionServlet.$anonfun$new$16(SessionServlet.scala:139) at org.scalatra.ScalatraBase.liftAction(ScalatraBase.scala:280) at org.scalatra.ScalatraBase.$anonfun$invoke$1(ScalatraBase.scala:274) at org.scalatra.ApiFormats.withRouteMultiParams(ApiFormats.scala:183) at org.scalatra.ApiFormats.withRouteMultiParams$(ApiFormats.scala:169) at org.apache.livy.server.JsonServlet.withRouteMultiParams(JsonServlet.scala:39) at org.scalatra.ScalatraBase.invoke(ScalatraBase.scala:273) at org.scalatra.ScalatraBase.invoke$(ScalatraBase.scala:272) at org.apache.livy.server.JsonServlet.invoke(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$runRoutes$3(ScalatraBase.scala:248) at scala.Option.flatMap(Option.scala:271) at org.scalatra.ScalatraBase.$anonfun$runRoutes$1(ScalatraBase.scala:246) at scala.collection.immutable.Stream.flatMap(Stream.scala:493) at org.scalatra.ScalatraBase.runRoutes(ScalatraBase.scala:245) at org.scalatra.ScalatraBase.runRoutes$(ScalatraBase.scala:243) at org.apache.livy.server.JsonServlet.runRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.runActions$1(ScalatraBase.scala:169) at org.scalatra.ScalatraBase.$anonfun$executeRoutes$6(ScalatraBase.scala:181) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at org.scalatra.ScalatraBase.cradleHalt(ScalatraBase.scala:199) at org.scalatra.ScalatraBase.executeRoutes(ScalatraBase.scala:181) at org.scalatra.ScalatraBase.executeRoutes$(ScalatraBase.scala:150) at org.apache.livy.server.JsonServlet.executeRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$handle$1(ScalatraBase.scala:123) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withResponse(DynamicScope.scala:79) at org.scalatra.DynamicScope.withResponse$(DynamicScope.scala:77) at org.apache.livy.server.JsonServlet.withResponse(JsonServlet.scala:39) at org.scalatra.DynamicScope.$anonfun$withRequestResponse$1(DynamicScope.scala:59) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withRequest(DynamicScope.scala:70) at org.scalatra.DynamicScope.withRequest$(DynamicScope.scala:68) at org.apache.livy.server.JsonServlet.withRequest(JsonServlet.scala:39) at org.scalatra.DynamicScope.withRequestResponse(DynamicScope.scala:58) at org.scalatra.DynamicScope.withRequestResponse$(DynamicScope.scala:56) at org.apache.livy.server.JsonServlet.withRequestResponse(JsonServlet.scala:39) at org.scalatra.ScalatraBase.handle(ScalatraBase.scala:123) at org.scalatra.ScalatraBase.handle$(ScalatraBase.scala:119) at org.apache.livy.server.JsonServlet.org$scalatra$servlet$ServletBase$$super$handle(JsonServlet.scala:39) at org.scalatra.servlet.ServletBase.handle(ServletBase.scala:53) at org.scalatra.servlet.ServletBase.handle$(ServletBase.scala:46) at org.apache.livy.server.SessionServlet.org$scalatra$MethodOverride$$super$handle(SessionServlet.scala:45) at org.scalatra.MethodOverride.handle(MethodOverride.scala:35) ...skipping... java.lang.IllegalStateException: failed to create a child event loop at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:88) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:58) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:47) at io.netty.channel.MultithreadEventLoopGroup.(MultithreadEventLoopGroup.java:59) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:77) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:72) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:59) at org.apache.livy.rsc.RSCClient.(RSCClient.java:81) at org.apache.livy.rsc.RSCClientFactory.createClient(RSCClientFactory.java:76) at org.apache.livy.LivyClientBuilder.build(LivyClientBuilder.java:130) at org.apache.livy.server.interactive.InteractiveSession$.$anonfun$create$1(InteractiveSession.scala:111) at scala.Option.orElse(Option.scala:447) at org.apache.livy.server.interactive.InteractiveSession$.create(InteractiveSession.scala:81) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:55) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:40) at org.apache.livy.server.SessionServlet.$anonfun$new$16(SessionServlet.scala:139) at org.scalatra.ScalatraBase.liftAction(ScalatraBase.scala:280) at org.scalatra.ScalatraBase.$anonfun$invoke$1(ScalatraBase.scala:274) at org.scalatra.ApiFormats.withRouteMultiParams(ApiFormats.scala:183) at org.scalatra.ApiFormats.withRouteMultiParams$(ApiFormats.scala:169) at org.apache.livy.server.JsonServlet.withRouteMultiParams(JsonServlet.scala:39) at org.scalatra.ScalatraBase.invoke(ScalatraBase.scala:273) at org.scalatra.ScalatraBase.invoke$(ScalatraBase.scala:272) at org.apache.livy.server.JsonServlet.invoke(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$runRoutes$3(ScalatraBase.scala:248) at scala.Option.flatMap(Option.scala:271) at org.scalatra.ScalatraBase.$anonfun$runRoutes$1(ScalatraBase.scala:246) at scala.collection.immutable.Stream.flatMap(Stream.scala:493) at org.scalatra.ScalatraBase.runRoutes(ScalatraBase.scala:245) at org.scalatra.ScalatraBase.runRoutes$(ScalatraBase.scala:243) at org.apache.livy.server.JsonServlet.runRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.runActions$1(ScalatraBase.scala:169) at org.scalatra.ScalatraBase.$anonfun$executeRoutes$6(ScalatraBase.scala:181) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at org.scalatra.ScalatraBase.cradleHalt(ScalatraBase.scala:199) at org.scalatra.ScalatraBase.executeRoutes(ScalatraBase.scala:181) at org.scalatra.ScalatraBase.executeRoutes$(ScalatraBase.scala:150) at org.apache.livy.server.JsonServlet.executeRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$handle$1(ScalatraBase.scala:123) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withResponse(DynamicScope.scala:79) at org.scalatra.DynamicScope.withResponse$(DynamicScope.scala:77) at org.apache.livy.server.JsonServlet.withResponse(JsonServlet.scala:39) at org.scalatra.DynamicScope.$anonfun$withRequestResponse$1(DynamicScope.scala:59) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withRequest(DynamicScope.scala:70) at org.scalatra.DynamicScope.withRequest$(DynamicScope.scala:68) at org.apache.livy.server.JsonServlet.withRequest(JsonServlet.scala:39) at org.scalatra.DynamicScope.withRequestResponse(DynamicScope.scala:58) at org.scalatra.DynamicScope.withRequestResponse$(DynamicScope.scala:56) at org.apache.livy.server.JsonServlet.withRequestResponse(JsonServlet.scala:39) at org.scalatra.ScalatraBase.handle(ScalatraBase.scala:123) at org.scalatra.ScalatraBase.handle$(ScalatraBase.scala:119) at org.apache.livy.server.JsonServlet.org$scalatra$servlet$ServletBase$$super$handle(JsonServlet.scala:39) at org.scalatra.servlet.ServletBase.handle(ServletBase.scala:53) at org.scalatra.servlet.ServletBase.handle$(ServletBase.scala:46) at org.apache.livy.server.SessionServlet.org$scalatra$MethodOverride$$super$handle(SessionServlet.scala:45) at org.scalatra.MethodOverride.handle(MethodOverride.scala:35) ...skipping... java.lang.IllegalStateException: failed to create a child event loop at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:88) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:58) at io.netty.util.concurrent.MultithreadEventExecutorGroup.(MultithreadEventExecutorGroup.java:47) at io.netty.channel.MultithreadEventLoopGroup.(MultithreadEventLoopGroup.java:59) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:77) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:72) at io.netty.channel.nio.NioEventLoopGroup.(NioEventLoopGroup.java:59) at org.apache.livy.rsc.RSCClient.(RSCClient.java:81) at org.apache.livy.rsc.RSCClientFactory.createClient(RSCClientFactory.java:76) at org.apache.livy.LivyClientBuilder.build(LivyClientBuilder.java:130) at org.apache.livy.server.interactive.InteractiveSession$.$anonfun$create$1(InteractiveSession.scala:111) at scala.Option.orElse(Option.scala:447) at org.apache.livy.server.interactive.InteractiveSession$.create(InteractiveSession.scala:81) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:55) at org.apache.livy.server.interactive.InteractiveSessionServlet.createSession(InteractiveSessionServlet.scala:40) at org.apache.livy.server.SessionServlet.$anonfun$new$16(SessionServlet.scala:139) at org.scalatra.ScalatraBase.liftAction(ScalatraBase.scala:280) at org.scalatra.ScalatraBase.$anonfun$invoke$1(ScalatraBase.scala:274) at org.scalatra.ApiFormats.withRouteMultiParams(ApiFormats.scala:183) at org.scalatra.ApiFormats.withRouteMultiParams$(ApiFormats.scala:169) at org.apache.livy.server.JsonServlet.withRouteMultiParams(JsonServlet.scala:39) at org.scalatra.ScalatraBase.invoke(ScalatraBase.scala:273) at org.scalatra.ScalatraBase.invoke$(ScalatraBase.scala:272) at org.apache.livy.server.JsonServlet.invoke(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$runRoutes$3(ScalatraBase.scala:248) at scala.Option.flatMap(Option.scala:271) at org.scalatra.ScalatraBase.$anonfun$runRoutes$1(ScalatraBase.scala:246) at scala.collection.immutable.Stream.flatMap(Stream.scala:493) at org.scalatra.ScalatraBase.runRoutes(ScalatraBase.scala:245) at org.scalatra.ScalatraBase.runRoutes$(ScalatraBase.scala:243) at org.apache.livy.server.JsonServlet.runRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.runActions$1(ScalatraBase.scala:169) at org.scalatra.ScalatraBase.$anonfun$executeRoutes$6(ScalatraBase.scala:181) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at org.scalatra.ScalatraBase.cradleHalt(ScalatraBase.scala:199) at org.scalatra.ScalatraBase.executeRoutes(ScalatraBase.scala:181) at org.scalatra.ScalatraBase.executeRoutes$(ScalatraBase.scala:150) at org.apache.livy.server.JsonServlet.executeRoutes(JsonServlet.scala:39) at org.scalatra.ScalatraBase.$anonfun$handle$1(ScalatraBase.scala:123) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withResponse(DynamicScope.scala:79) at org.scalatra.DynamicScope.withResponse$(DynamicScope.scala:77) at org.apache.livy.server.JsonServlet.withResponse(JsonServlet.scala:39) at org.scalatra.DynamicScope.$anonfun$withRequestResponse$1(DynamicScope.scala:59) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62) at org.scalatra.DynamicScope.withRequest(DynamicScope.scala:70) at org.scalatra.DynamicScope.withRequest$(DynamicScope.scala:68) at org.apache.livy.server.JsonServlet.withRequest(JsonServlet.scala:39) at org.scalatra.DynamicScope.withRequestResponse(DynamicScope.scala:58) at org.scalatra.DynamicScope.withRequestResponse$(DynamicScope.scala:56) at org.apache.livy.server.JsonServlet.withRequestResponse(JsonServlet.scala:39) at org.scalatra.ScalatraBase.handle(ScalatraBase.scala:123) at org.scalatra.ScalatraBase.handle$(ScalatraBase.scala:119) at org.apache.livy.server.JsonServlet.org$scalatra$servlet$ServletBase$$super$handle(JsonServlet.scala:39) at org.scalatra.servlet.ServletBase.handle(ServletBase.scala:53) at org.scalatra.servlet.ServletBase.handle$(ServletBase.scala:46) at org.apache.livy.server.SessionServlet.org$scalatra$MethodOverride$$super$handle(SessionServlet.scala:45) at org.scalatra.MethodOverride.handle(MethodOverride.scala:35) ...skipping... java.lang.IllegalArgumentException: Unexpected client ID 'b16bf0de-eef6-4f65-a66d-17d67d769bfc' in SASL handshake. at org.apache.livy.rsc.Utils.checkArgument(Utils.java:42) at org.apache.livy.rsc.rpc.RpcServer$SaslServerHandler.update(RpcServer.java:288) at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:61) at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:36) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) at io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:103) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:138) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459) at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) at java.lang.Thread.run(Thread.java:748) 21/02/05 14:25:28 WARN DefaultChannelPipeline: An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception. java.lang.IllegalArgumentException: Unexpected client ID 'b16bf0de-eef6-4f65-a66d-17d67d769bfc' in SASL handshake. at org.apache.livy.rsc.Utils.checkArgument(Utils.java:42) at org.apache.livy.rsc.rpc.RpcServer$SaslServerHandler.update(RpcServer.java:288) at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:61) at org.apache.livy.rsc.rpc.SaslHandler.channelRead0(SaslHandler.java:36) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) at io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:103) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:138) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459) at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) at java.lang.Thread.run(Thread.java:748)