(hudi) branch master updated: [MINOR] Fix and enable test TestHoodieDeltaStreamer.testJdbcSourceIncrementalFetchInContinuousMode (#10867)

[danny0405]

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

danny0405 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 f8f12ba9ef3 [MINOR] Fix and enable test 
TestHoodieDeltaStreamer.testJdbcSourceIncrementalFetchInContinuousMode (#10867)
f8f12ba9ef3 is described below

commit f8f12ba9ef31aed54a9e97057822777cd8f16de5
Author: wombatu-kun <wombatu...@gmail.com>
AuthorDate: Fri Mar 15 07:33:04 2024 +0700

    [MINOR] Fix and enable test 
TestHoodieDeltaStreamer.testJdbcSourceIncrementalFetchInContinuousMode (#10867)
    
    Co-authored-by: Vova Kolmakov <kolmakov.vladi...@huawei-partners.com>
---
 .../deltastreamer/TestHoodieDeltaStreamer.java         | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
index 108d1cc8a87..73f37edc6c7 100644
--- 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
+++ 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
@@ -2415,21 +2415,19 @@ public class TestHoodieDeltaStreamer extends 
HoodieDeltaStreamerTestBase {
     assertRecordCount(SQL_SOURCE_NUM_RECORDS, tableBasePath, sqlContext);
   }
 
-  @Disabled
   @Test
   public void testJdbcSourceIncrementalFetchInContinuousMode() {
-    try (Connection connection = 
DriverManager.getConnection("jdbc:h2:mem:test_mem", "test", "jdbc")) {
+    try (Connection connection = 
DriverManager.getConnection("jdbc:h2:mem:test_mem", "sa", "")) {
       TypedProperties props = new TypedProperties();
-      props.setProperty("hoodie.deltastreamer.jdbc.url", 
"jdbc:h2:mem:test_mem");
-      props.setProperty("hoodie.deltastreamer.jdbc.driver.class", 
"org.h2.Driver");
-      props.setProperty("hoodie.deltastreamer.jdbc.user", "test");
-      props.setProperty("hoodie.deltastreamer.jdbc.password", "jdbc");
-      props.setProperty("hoodie.deltastreamer.jdbc.table.name", "triprec");
-      props.setProperty("hoodie.deltastreamer.jdbc.incr.pull", "true");
-      props.setProperty("hoodie.deltastreamer.jdbc.table.incr.column.name", 
"id");
+      props.setProperty("hoodie.streamer.jdbc.url", "jdbc:h2:mem:test_mem");
+      props.setProperty("hoodie.streamer.jdbc.driver.class", "org.h2.Driver");
+      props.setProperty("hoodie.streamer.jdbc.user", "sa");
+      props.setProperty("hoodie.streamer.jdbc.password", "");
+      props.setProperty("hoodie.streamer.jdbc.table.name", "triprec");
+      props.setProperty("hoodie.streamer.jdbc.incr.pull", "true");
+      props.setProperty("hoodie.streamer.jdbc.table.incr.column.name", "id");
 
       props.setProperty("hoodie.datasource.write.recordkey.field", "ID");
-      props.setProperty("hoodie.datasource.write.partitionpath.field", 
"partition_path");
 
       UtilitiesTestBase.Helpers.savePropsToDFS(props, fs, basePath + 
"/test-jdbc-source.properties");