(hudi) branch master updated: [HUDI-8277] Update wait time in ITTestDataStreamWrite#execute to prevent unit test failures (#12027)

[da...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 67a060321be [HUDI-8277] Update wait time in ITTestDataStreamWrite#execute to prevent unit test failures (#12027)
67a060321be is described below

commit 67a060321bee90c180088a6d1c40ec354f07a187
Author: usberkeley <15...@users.noreply.github.com>
AuthorDate: Tue Oct 1 09:06:44 2024 +0800

    [HUDI-8277] Update wait time in ITTestDataStreamWrite#execute to prevent unit test failures (#12027)
---
 .../src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
index 47c613ec784..a5d3b3ece4d 100644
--- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
+++ b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
@@ -329,7 +329,7 @@ public class ITTestDataStreamWrite extends TestLogger {
       JobClient client = execEnv.executeAsync(jobName);
       if (client.getJobStatus().get() != JobStatus.FAILED) {
         try {
-          TimeUnit.SECONDS.sleep(20); // wait long enough for the compaction to finish
+          TimeUnit.SECONDS.sleep(35); // wait long enough for the compaction to finish
           client.cancel();
         } catch (Throwable var1) {
           // ignored