You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yi...@apache.org on 2023/02/04 05:53:10 UTC
[hudi] 05/07: [HUDI-5653] Reset TestDataSource for TestHoodieDeltaStreamerWithMultiWriter (#7831)
This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch release-0.13.0
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 9af629c63096edc2533c1f63407443d419015a09
Author: Jon Vexler <jb...@gmail.com>
AuthorDate: Fri Feb 3 12:39:56 2023 -0500
[HUDI-5653] Reset TestDataSource for TestHoodieDeltaStreamerWithMultiWriter (#7831)
Co-authored-by: Jonathan Vexler <=>
---
.../deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java
index 4c03e1c67f2..df17a88156a 100644
--- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java
+++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java
@@ -36,6 +36,7 @@ import org.apache.hudi.utilities.testutils.sources.config.SourceConfigs;
import org.apache.hadoop.fs.FileSystem;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
+import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.params.ParameterizedTest;
@@ -72,8 +73,12 @@ public class TestHoodieDeltaStreamerWithMultiWriter extends SparkClientFunctiona
String basePath;
String propsFilePath;
String tableBasePath;
+
+ @AfterEach
+ public void teardown() throws Exception {
+ TestDataSource.resetDataGen();
+ }
- @Disabled("HUDI-5653")
@ParameterizedTest
@EnumSource(HoodieTableType.class)
void testUpsertsContinuousModeWithMultipleWritersForConflicts(HoodieTableType tableType) throws Exception {