(hudi) branch master updated: [MINOR] Fixing integ test writer for commit time generation (#10243)

[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 b355a3f6b3b [MINOR] Fixing integ test writer for commit time 
generation (#10243)
b355a3f6b3b is described below

commit b355a3f6b3be6b1a3f68b034963a15eb8eb0b618
Author: Sivabalan Narayanan <n.siv...@gmail.com>
AuthorDate: Wed Dec 6 16:04:15 2023 -0800

    [MINOR] Fixing integ test writer for commit time generation (#10243)
---
 .../java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java
 
b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java
index 75d3fd94101..e06e793f07c 100644
--- 
a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java
+++ 
b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java
@@ -76,9 +76,7 @@ public abstract class HoodieTestSuiteWriter implements 
Serializable {
     this.deltaStreamerWrapper = new HoodieDeltaStreamerWrapper(cfg, jsc);
     this.hoodieReadClient = new HoodieReadClient(context, cfg.targetBasePath);
     this.writeConfig = getHoodieClientConfig(cfg, props, schema);
-    if (!cfg.useDeltaStreamer) {
-      this.writeClient = new SparkRDDWriteClient(context, writeConfig);
-    }
+    this.writeClient = new SparkRDDWriteClient(context, writeConfig);
     this.cfg = cfg;
     this.configuration = jsc.hadoopConfiguration();
     this.sparkContext = jsc;