[
https://issues.apache.org/jira/browse/FLINK-38403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18023044#comment-18023044
]
Zakelly Lan commented on FLINK-38403:
-------------------------------------
Besides, I found a suspicious TM lost:
{code:java}
Sink: sink (3/5)#3
(f9992f7a28b35a6b3d973841daf88aa2_2e588ce1c86a9d46e2e85186773ce4fd_2_3)
switched from RUNNING to FAILED with failure cause:
org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException:
Connection unexpectedly closed by remote task manager
'localhost/127.0.0.1:42939 [ 554f2bd6-acb5-4aa4-8ed3-fcdc9bbef8fe ] '. This
might indicate that the remote task manager was lost.
at
org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler.channelInactive(CreditBasedPartitionRequestClientHandler.java:140)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:305)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.runtime.io.network.netty.NettyMessageClientDecoderDelegate.channelInactive(NettyMessageClientDecoderDelegate.java:94)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:305)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:813)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:413)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at
org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
~[flink-shaded-netty-4.1.100.Final-20.0.jar:?]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
{code}
Which will cause the exception of NoResourceAvailableException.
> UnalignedCheckpointITCase failed in test_cron_hadoop313 tests
> -------------------------------------------------------------
>
> Key: FLINK-38403
> URL: https://issues.apache.org/jira/browse/FLINK-38403
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 2.2.0
> Reporter: Ruan Hang
> Priority: Major
>
> Details:
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=69810&view=logs&j=baf26b34-3c6a-54e8-f93f-cf269b32f802&t=b380e762-00fc-5c06-e76c-b8e53634ca34
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
