[hudi] branch master updated: [MINOR] fixing flaky tests in deltastreamer tests (#5521)

[sivabalan]

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

sivabalan 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 569a76a9a5 [MINOR] fixing flaky tests in deltastreamer tests (#5521)
569a76a9a5 is described below

commit 569a76a9a5389efb74ec88b81c616f8ead58df5c
Author: Sivabalan Narayanan <n.siv...@gmail.com>
AuthorDate: Sat May 7 15:37:20 2022 -0400

    [MINOR] fixing flaky tests in deltastreamer tests (#5521)
---
 .../apache/hudi/utilities/functional/HoodieDeltaStreamerTestBase.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/HoodieDeltaStreamerTestBase.java
 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/HoodieDeltaStreamerTestBase.java
index a9de85ce5a..4ac6f73d88 100644
--- 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/HoodieDeltaStreamerTestBase.java
+++ 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/HoodieDeltaStreamerTestBase.java
@@ -30,6 +30,7 @@ import org.apache.hudi.common.util.Option;
 import org.apache.hudi.hive.HiveSyncConfig;
 import org.apache.hudi.hive.MultiPartKeysValueExtractor;
 import org.apache.hudi.utilities.schema.FilebasedSchemaProvider;
+import org.apache.hudi.utilities.sources.TestParquetDFSSourceEmptyBatch;
 import org.apache.hudi.utilities.testutils.UtilitiesTestBase;
 
 import org.apache.avro.Schema;
@@ -191,6 +192,7 @@ public class HoodieDeltaStreamerTestBase extends 
UtilitiesTestBase {
   @BeforeEach
   public void setup() throws Exception {
     super.setup();
+    TestParquetDFSSourceEmptyBatch.returnEmptyBatch = false;
   }
 
   @AfterAll