[flink] branch master updated: [FLINK-27703][core] Extend timeout and add logs for FileChannelManagerImplTest

[hxb]

This is an automated email from the ASF dual-hosted git repository.

hxb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 4f7ebbb4f91 [FLINK-27703][core] Extend timeout and add logs for 
FileChannelManagerImplTest
4f7ebbb4f91 is described below

commit 4f7ebbb4f91ad27aaf89c8c035031efe91b84171
Author: Yun Gao <gaoyunhen...@gmail.com>
AuthorDate: Mon Jul 11 13:58:10 2022 +0800

    [FLINK-27703][core] Extend timeout and add logs for 
FileChannelManagerImplTest
    
    This closes #20239.
---
 .../apache/flink/runtime/io/disk/FileChannelManagerImplTest.java  | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/FileChannelManagerImplTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/FileChannelManagerImplTest.java
index f4aeffed05d..dc96ea654e2 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/FileChannelManagerImplTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/FileChannelManagerImplTest.java
@@ -124,7 +124,7 @@ public class FileChannelManagerImplTest extends TestLogger {
 
             // Waits till the process has created temporary files and 
registered the corresponding
             // shutdown hooks.
-            TestJvmProcess.waitForMarkerFile(signalFile, 
TEST_TIMEOUT.toMillis());
+            TestJvmProcess.waitForMarkerFile(signalFile, 3 * 
TEST_TIMEOUT.toMillis());
 
             Process kill =
                     Runtime.getRuntime()
@@ -196,6 +196,8 @@ public class FileChannelManagerImplTest extends TestLogger {
             String tmpDirectory = args[1];
             String signalFilePath = args[2];
 
+            LOG.info("The FileChannelManagerCleanupRunner process has 
started");
+
             FileChannelManager manager =
                     new FileChannelManagerImpl(new String[] {tmpDirectory}, 
DIR_NAME_PREFIX);
 
@@ -205,9 +207,13 @@ public class FileChannelManagerImplTest extends TestLogger 
{
                 ShutdownHookUtil.addShutdownHook(() -> manager.close(), 
"Caller", LOG);
             }
 
+            LOG.info("The FileChannelManagerCleanupRunner is going to create 
the new file");
+
             // Signals the main process to execute the kill action.
             new File(signalFilePath).createNewFile();
 
+            LOG.info("The FileChannelManagerCleanupRunner has created the new 
file");
+
             // Blocks the process to wait to be killed.
             Thread.sleep(3 * TEST_TIMEOUT.toMillis());
         }