(paimon) branch master updated: [test] Fix unstable test: ConsumerActionITCase.testResetConsumer

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 06cbee0df [test] Fix unstable test: 
ConsumerActionITCase.testResetConsumer
06cbee0df is described below

commit 06cbee0dff091c64d9f08c5ac5d67c369c8b5eaa
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Wed Aug 7 11:42:21 2024 +0800

    [test] Fix unstable test: ConsumerActionITCase.testResetConsumer
---
 .../test/java/org/apache/paimon/flink/action/ConsumerActionITCase.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ConsumerActionITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ConsumerActionITCase.java
index 6a17a4512..8b3968f95 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ConsumerActionITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ConsumerActionITCase.java
@@ -79,6 +79,7 @@ public class ConsumerActionITCase extends ActionITCaseBase {
                                 changelogRow("+I", 3L, "Paimon")))
                 .close();
 
+        Thread.sleep(1000);
         ConsumerManager consumerManager = new ConsumerManager(table.fileIO(), 
table.location());
         Optional<Consumer> consumer1 = consumerManager.consumer("myid");
         assertThat(consumer1).isPresent();