[
https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403712#comment-17403712
]
Yingjie Cao commented on FLINK-23466:
-------------------------------------
Update:
After running the test over one day. I think I finally reproduced the case. The
case "hung" there for a very long time, but finally, it succeeded. The common
stack among the three cases is:
{code:java}
"Source: source (16/20)#4" #10439 prio=5 os_prio=31 tid=0x00007f93973a2000
nid=0x4c91b sleeping[0x000070000b228000]
java.lang.Thread.State: TIMED_WAITING (sleeping)
at java.lang.Thread.sleep(Native Method)
at
org.apache.flink.test.checkpointing.UnalignedCheckpointTestBase$LongSource$LongSourceReader.pollNext(UnalignedCheckpointTestBase.java:319)
at
org.apache.flink.streaming.api.operators.SourceOperator.pollNext(SourceOperator.java:365)
at
org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:325)
at
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:489)
at
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$1091/178711115.runDefaultAction(Unknown
Source)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:819)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:746)
at
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$1279/2130631630.run(Unknown
Source)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:785)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:728)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:786)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:572)
at java.lang.Thread.run(Thread.java:748)
{code}
I guess this maybe a purely test case issue. I will further analysis it to find
out why the thread stuck there that long.
> UnalignedCheckpointITCase hangs on Azure
> ----------------------------------------
>
> Key: FLINK-23466
> URL: https://issues.apache.org/jira/browse/FLINK-23466
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.14.0
> Reporter: Dawid Wysakowicz
> Assignee: Yingjie Cao
> Priority: Critical
> Labels: test-stability
> Fix For: 1.14.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=20813&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7&l=16016
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
