[ 
https://issues.apache.org/jira/browse/FLINK-34424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817251#comment-17817251
 ] 

Piotr Nowojski commented on FLINK-34424:
----------------------------------------

:D

[~mapohl] I haven't made any modifications to this area of code since a very 
long time and I unfortunately recently don't have much time to investigate this 
kind of issues. I would suggest to ping someone else. Maybe authors of the most 
recent change to this test file: FLINK-33743


> BoundedBlockingSubpartitionWriteReadTest#testRead10ConsumersConcurrent times 
> out
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-34424
>                 URL: https://issues.apache.org/jira/browse/FLINK-34424
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Network
>    Affects Versions: 1.19.0, 1.20.0
>            Reporter: Matthias Pohl
>            Priority: Critical
>              Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=57446&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=24c3384f-1bcb-57b3-224f-51bf973bbee8&l=9151
> {code}
> Feb 11 13:55:29 "ForkJoinPool-50-worker-25" #414 daemon prio=5 os_prio=0 
> tid=0x00007f19503af800 nid=0x284c in Object.wait() [0x00007f191b6db000]
> Feb 11 13:55:29    java.lang.Thread.State: WAITING (on object monitor)
> Feb 11 13:55:29       at java.lang.Object.wait(Native Method)
> Feb 11 13:55:29       at java.lang.Thread.join(Thread.java:1252)
> Feb 11 13:55:29       - locked <0x00000000e2e019a8> (a 
> org.apache.flink.runtime.io.network.partition.BoundedBlockingSubpartitionWriteReadTest$LongReader)
> Feb 11 13:55:29       at 
> org.apache.flink.core.testutils.CheckedThread.trySync(CheckedThread.java:104)
> Feb 11 13:55:29       at 
> org.apache.flink.core.testutils.CheckedThread.sync(CheckedThread.java:92)
> Feb 11 13:55:29       at 
> org.apache.flink.core.testutils.CheckedThread.sync(CheckedThread.java:81)
> Feb 11 13:55:29       at 
> org.apache.flink.runtime.io.network.partition.BoundedBlockingSubpartitionWriteReadTest.testRead10ConsumersConcurrent(BoundedBlockingSubpartitionWriteReadTest.java:177)
> Feb 11 13:55:29       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native 
> Method)
> [...]
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to