Martijn Visser created FLINK-39134:
--------------------------------------
Summary:
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
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)
