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 <[email protected]>
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
