lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] fixing flaky tests in deltastreamer tests (#5521)

Browse Source
This commit is contained in:
Sivabalan Narayanan
2022-05-07 15:37:20 -04:00
committed by GitHub
parent 80f99893a0
commit 569a76a9a5
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/HoodieDeltaStreamerTestBase.java
View File

@@ -30,6 +30,7 @@ import org.apache.hudi.common.util.Option;
import org.apache.hudi.hive.HiveSyncConfig; import org.apache.hudi.hive.HiveSyncConfig;
import org.apache.hudi.hive.MultiPartKeysValueExtractor; import org.apache.hudi.hive.MultiPartKeysValueExtractor;
import org.apache.hudi.utilities.schema.FilebasedSchemaProvider; import org.apache.hudi.utilities.schema.FilebasedSchemaProvider;
import org.apache.hudi.utilities.sources.TestParquetDFSSourceEmptyBatch;
import org.apache.hudi.utilities.testutils.UtilitiesTestBase; import org.apache.hudi.utilities.testutils.UtilitiesTestBase;
import org.apache.avro.Schema; import org.apache.avro.Schema;
@@ -191,6 +192,7 @@ public class HoodieDeltaStreamerTestBase extends UtilitiesTestBase {
@BeforeEach @BeforeEach
public void setup() throws Exception { public void setup() throws Exception {
super.setup(); super.setup();
TestParquetDFSSourceEmptyBatch.returnEmptyBatch = false;
} }
@AfterAll @AfterAll