(hudi) branch master updated: [HUDI-8696] Remove TestHoodieMultiTableDeltaStreamer#testInvalidIngestionProps (#12654)

[wombatukun]

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

wombatukun 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 dee6274e56d [HUDI-8696] Remove 
TestHoodieMultiTableDeltaStreamer#testInvalidIngestionProps (#12654)
dee6274e56d is described below

commit dee6274e56d8b7d3852104d3e45377f4909466cd
Author: Lokesh Jain <lj...@apache.org>
AuthorDate: Fri Jan 17 12:58:07 2025 +0530

    [HUDI-8696] Remove 
TestHoodieMultiTableDeltaStreamer#testInvalidIngestionProps (#12654)
---
 .../deltastreamer/TestHoodieMultiTableDeltaStreamer.java   | 14 +-------------
 1 file changed, 1 insertion(+), 13 deletions(-)

diff --git 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieMultiTableDeltaStreamer.java
 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieMultiTableDeltaStreamer.java
index a8197ca58f3..a0084215950 100644
--- 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieMultiTableDeltaStreamer.java
+++ 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieMultiTableDeltaStreamer.java
@@ -34,7 +34,6 @@ import org.apache.hudi.utilities.sources.TestDataSource;
 import org.apache.hudi.utilities.streamer.TableExecutionContext;
 import org.apache.hudi.utilities.testutils.UtilitiesTestBase;
 
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -150,18 +149,7 @@ public class TestHoodieMultiTableDeltaStreamer extends 
HoodieDeltaStreamerTestBa
         
getStringWithAltKeys(streamer.getTableExecutionContexts().get(0).getProperties(),
             HoodieSchemaProviderConfig.SRC_SCHEMA_REGISTRY_URL));
   }
-
-  @Test
-  @Disabled
-  public void testInvalidIngestionProps() {
-    Exception e = assertThrows(Exception.class, () -> {
-      HoodieMultiTableDeltaStreamer.Config cfg = 
TestHelpers.getConfig(PROPS_FILENAME_TEST_SOURCE1, basePath + "/config", 
TestDataSource.class.getName(), true, true, null);
-      new HoodieMultiTableDeltaStreamer(cfg, jsc);
-    }, "Creation of execution object should fail without kafka topic");
-    LOG.debug("Creation of execution object failed with error: " + 
e.getMessage(), e);
-    assertTrue(e.getMessage().contains("Please provide valid table config 
arguments!"));
-  }
-
+  
   @Test //0 corresponds to fg
   public void testMultiTableExecutionWithKafkaSource() throws IOException {
     //create topics for each table