[FLINK-33115] AbstractHadoopRecoverableWriterITCase is hanging with timeout on AZP

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 1.18.0, 1.19.0, 1.17.3
• Component/s: Tests
• Labels: stale-critical test-stability
• Assignee: Samrat Deb
• Reporter: Sergey Nuyanzin
• Created: 19/Sep/23 09:24
• Updated: 17/Jan/24 07:48

Description

This build https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=53281&view=logs&j=4eda0b4a-bd0d-521a-0916-8285b9be9bb5&t=2ff6d5fa-53a6-53ac-bff7-fa524ea361a9&l=14239
is failing as

Sep 15 11:33:02 ==============================================================================
Sep 15 11:33:02 Process produced no output for 900 seconds.
Sep 15 11:33:02 ==============================================================================

...
Sep 15 11:33:03 	at java.io.DataInputStream.read(DataInputStream.java:149)
Sep 15 11:33:03 	at org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream.read(HadoopDataInputStream.java:96)
Sep 15 11:33:03 	at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
Sep 15 11:33:03 	at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
Sep 15 11:33:03 	at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
Sep 15 11:33:03 	- locked <0x00000000bfa7a760> (a java.io.InputStreamReader)
Sep 15 11:33:03 	at java.io.InputStreamReader.read(InputStreamReader.java:184)
Sep 15 11:33:03 	at java.io.BufferedReader.fill(BufferedReader.java:161)
Sep 15 11:33:03 	at java.io.BufferedReader.readLine(BufferedReader.java:324)
Sep 15 11:33:03 	- locked <0x00000000bfa7a760> (a java.io.InputStreamReader)
Sep 15 11:33:03 	at java.io.BufferedReader.readLine(BufferedReader.java:389)
Sep 15 11:33:03 	at org.apache.flink.runtime.fs.hdfs.AbstractHadoopRecoverableWriterITCase.getContentsOfFile(AbstractHadoopRecoverableWriterITCase.java:387)
Sep 15 11:33:03 	at org.apache.flink.runtime.fs.hdfs.AbstractHadoopRecoverableWriterITCase.testResumeAfterMultiplePersist(AbstractHadoopRecoverableWriterITCase.java:377)
Sep 15 11:33:03 	at org.apache.flink.runtime.fs.hdfs.AbstractHadoopRecoverableWriterITCase.testResumeAfterMultiplePersistWithMultiPartUploads(AbstractHadoopRecoverableWriterITCase.java:330)
Sep 15 11:33:03 	at org.apache.flink.runtime.fs.hdfs.AbstractHadoopRecoverableWri
...

Issue Links

• is duplicated by: FLINK-33574 testRecoverAfterMultiplePersistsStateWithMultiPart andtestRecoverAfterMultiplePersistsStateWithMultiPart run into timeouts