Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34644

RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException

    XMLWordPrintableJSON

Details

    Description

      https://github.com/apache/flink/actions/runs/8189958608/job/22396362238#step:10:9215

      Error: 15:13:33 15:13:33.779 [ERROR] Tests run: 68, Failures: 0, Errors: 1, Skipped: 4, Time elapsed: 17.81 s <<< FAILURE! -- in org.apache.flink.runtime.rest.RestServerEndpointITCase
      Error: 15:13:33 15:13:33.779 [ERROR] org.apache.flink.runtime.rest.RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing -- Time elapsed: 0.329 s <<< ERROR!
      Mar 07 15:13:33 java.util.concurrent.ExecutionException: org.apache.flink.runtime.rest.ConnectionClosedException: Channel became inactive.
      Mar 07 15:13:33 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
      Mar 07 15:13:33 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
      Mar 07 15:13:33 	at org.apache.flink.runtime.rest.RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing(RestServerEndpointITCase.java:592)
      Mar 07 15:13:33 	at java.lang.reflect.Method.invoke(Method.java:498)
      Mar 07 15:13:33 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
      Mar 07 15:13:33 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
      Mar 07 15:13:33 	at java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
      Mar 07 15:13:33 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
      Mar 07 15:13:33 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
      Mar 07 15:13:33 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
      Mar 07 15:13:33 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
      Mar 07 15:13:33 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
      Mar 07 15:13:33 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
      Mar 07 15:13:33 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
      Mar 07 15:13:33 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
      Mar 07 15:13:33 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
      Mar 07 15:13:33 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
      Mar 07 15:13:33 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
      Mar 07 15:13:33 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
      Mar 07 15:13:33 	at java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
      Mar 07 15:13:33 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
      Mar 07 15:13:33 	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
      Mar 07 15:13:33 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
      Mar 07 15:13:33 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
      Mar 07 15:13:33 Caused by: org.apache.flink.runtime.rest.ConnectionClosedException: Channel became inactive.
      Mar 07 15:13:33 	at org.apache.flink.runtime.rest.RestClient$ClientHandler.channelInactive(RestClient.java:749)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:305)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.timeout.IdleStateHandler.channelInactive(IdleStateHandler.java:277)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.stream.ChunkedWriteHandler.channelInactive(ChunkedWriteHandler.java:137)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.channelInactive(MessageAggregator.java:441)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:305)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelInactive(CombinedChannelDuplexHandler.java:418)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:411)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:376)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:329)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:221)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:411)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:376)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler.channelInactive(SslHandler.java:1085)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:305)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:813)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
      Mar 07 15:13:33 	at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
      Mar 07 15:13:33 	at java.lang.Thread.run(Thread.java:750)
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            mapohl Matthias Pohl
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: