[
https://issues.apache.org/jira/browse/FLINK-39134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18060154#comment-18060154
]
Efrat Levitan commented on FLINK-39134:
---------------------------------------
[~fanrui] maybe related to https://issues.apache.org/jira/browse/FLINK-38804?
> UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is
> flaky
> -----------------------------------------------------------------------------------
>
> Key: FLINK-39134
> URL: https://issues.apache.org/jira/browse/FLINK-39134
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Reporter: Martijn Visser
> Assignee: Roman Khachatryan
> Priority: Major
> Fix For: 2.3.0
>
>
> {code:java}
> "Channel state writer" #133 daemon prio=5 os_prio=0 cpu=1245219.64ms
> elapsed=12505.30s tid=0x00007f56d5cef000 nid=0x76ed runnable
> [0x00007f56d18fc000]
> java.lang.Thread.State: RUNNABLE
> at java.io.FileDescriptor.sync([email protected]/Native Method)
> at
> org.apache.flink.core.fs.local.LocalDataOutputStream.sync(LocalDataOutputStream.java:86)
> at
> org.apache.flink.core.fs.FSDataOutputStreamWrapper.sync(FSDataOutputStreamWrapper.java:50)
> at
> org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream.sync(FsCheckpointStreamFactory.java:335)
> at
> org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream.closeAndGetHandle(FsCheckpointStreamFactory.java:408)
> - locked <0x00000000aeaee3b0> (a
> org.apache.flink.test.checkpointing.UnalignedCheckpointFailureHandlingITCase$FailingOnceFsCheckpointOutputStream)
> at
> org.apache.flink.test.checkpointing.UnalignedCheckpointFailureHandlingITCase$FailingOnceFsCheckpointOutputStream.closeAndGetHandle(UnalignedCheckpointFailureHandlingITCase.java:355)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.finishWriteAndResult(ChannelStateCheckpointWriter.java:246)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter$$Lambda$2252/0x00000008018a62d0.run(Unknown
> Source)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.doComplete(ChannelStateCheckpointWriter.java:255)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.lambda$tryFinishResult$3(ChannelStateCheckpointWriter.java:236)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter$$Lambda$2251/0x00000008018a5820.run(Unknown
> Source)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.runWithChecks(ChannelStateCheckpointWriter.java:274)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.tryFinishResult(ChannelStateCheckpointWriter.java:236)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.completeInput(ChannelStateCheckpointWriter.java:208)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequest.lambda$completeInput$0(ChannelStateWriteRequest.java:114)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequest$$Lambda$2167/0x000000080185fd80.accept(Unknown
> Source)
> at
> org.apache.flink.runtime.checkpoint.channel.CheckpointInProgressRequest.execute(ChannelStateWriteRequest.java:366)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestDispatcherImpl.handleCheckpointInProgressRequest(ChannelStateWriteRequestDispatcherImpl.java:175)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestDispatcherImpl.dispatchInternal(ChannelStateWriteRequestDispatcherImpl.java:125)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestDispatcherImpl.dispatch(ChannelStateWriteRequestDispatcherImpl.java:92)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.loop(ChannelStateWriteRequestExecutorImpl.java:182)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.run(ChannelStateWriteRequestExecutorImpl.java:136)
> at
> org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl$$Lambda$1722/0x000000080179bc90.run(Unknown
> Source)
> at java.lang.Thread.run([email protected]/Thread.java:833)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=72563&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49&t=9d734c8c-6253-55e6-3bce-47e7cdf68ac4&l=49080
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
