[
https://issues.apache.org/jira/browse/FLINK-34644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830837#comment-17830837
]
Ryan Skraba commented on FLINK-34644:
-------------------------------------
https://github.com/apache/flink/actions/runs/8423217883/job/23064824741#step:10:9197
> RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with
> ConnectionClosedException
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-34644
> URL: https://issues.apache.org/jira/browse/FLINK-34644
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.20.0
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> https://github.com/apache/flink/actions/runs/8189958608/job/22396362238#step:10:9215
> {code}
> 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)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
