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

fanjia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git


The following commit(s) were added to refs/heads/main by this push:
     new 1df50cf7 [Bug] [Seatunnel-web][Hive] Hive data source is not appearing 
in UI during the configuration of the Hive source. (#211)
1df50cf7 is described below

commit 1df50cf7907bc267b27fc8fd9ef437b05c8ebd29
Author: Mohammad Arshad <[email protected]>
AuthorDate: Tue Sep 10 08:02:42 2024 +0530

    [Bug] [Seatunnel-web][Hive] Hive data source is not appearing in UI during 
the configuration of the Hive source. (#211)
---
 .../main/resources/connector-datasource-mapper.yaml    | 18 +++++++++++++++++-
 .../org/apache/seatunnel/app/utils/JobUtilsTests.java  |  7 ++-----
 2 files changed, 19 insertions(+), 6 deletions(-)

diff --git 
a/seatunnel-server/seatunnel-app/src/main/resources/connector-datasource-mapper.yaml
 
b/seatunnel-server/seatunnel-app/src/main/resources/connector-datasource-mapper.yaml
index 0ba9a780..9dabf7b6 100644
--- 
a/seatunnel-server/seatunnel-app/src/main/resources/connector-datasource-mapper.yaml
+++ 
b/seatunnel-server/seatunnel-app/src/main/resources/connector-datasource-mapper.yaml
@@ -67,6 +67,10 @@ connector-datasource-mapper:
       dataSources:
         - Console
 
+    Hive:
+      dataSources:
+        - Hive
+
   sourceDatasourceFeatures:
     JDBC-Mysql:
       businessMode:
@@ -156,6 +160,12 @@ connector-datasource-mapper:
         - SINGLE_TABLE
         - MULTIPLE_TABLE
 
+    Hive:
+      businessMode:
+        - DATA_INTEGRATION
+      sceneMode:
+        - SINGLE_TABLE
+        - MULTIPLE_TABLE
   sinkDatasourceFeatures:
     JDBC-Mysql:
       businessMode:
@@ -247,4 +257,10 @@ connector-datasource-mapper:
         - DATA_REPLICA
       sceneMode:
         - SINGLE_TABLE
-        - MULTIPLE_TABLE
\ No newline at end of file
+        - MULTIPLE_TABLE
+
+    Hive:
+      businessMode:
+        - DATA_INTEGRATION
+      sceneMode:
+        - SINGLE_TABLE
\ No newline at end of file
diff --git 
a/seatunnel-server/seatunnel-app/src/test/java/org/apache/seatunnel/app/utils/JobUtilsTests.java
 
b/seatunnel-server/seatunnel-app/src/test/java/org/apache/seatunnel/app/utils/JobUtilsTests.java
index 31c37fb9..dca59073 100644
--- 
a/seatunnel-server/seatunnel-app/src/test/java/org/apache/seatunnel/app/utils/JobUtilsTests.java
+++ 
b/seatunnel-server/seatunnel-app/src/test/java/org/apache/seatunnel/app/utils/JobUtilsTests.java
@@ -22,7 +22,6 @@ import 
org.apache.seatunnel.shade.com.typesafe.config.ConfigFactory;
 import org.apache.seatunnel.app.domain.request.job.JobExecParam;
 import org.apache.seatunnel.server.common.SeatunnelException;
 
-import org.jetbrains.annotations.NotNull;
 import org.junit.jupiter.api.Test;
 
 import java.util.HashMap;
@@ -87,9 +86,7 @@ public class JobUtilsTests {
 
         assertThrows(
                 SeatunnelException.class,
-                () -> {
-                    JobUtils.replaceJobConfigPlaceholders(jobConfigContent, 
jobExecParam);
-                });
+                () -> JobUtils.replaceJobConfigPlaceholders(jobConfigContent, 
jobExecParam));
     }
 
     @Test
@@ -112,7 +109,7 @@ public class JobUtilsTests {
         assertNotNull(config);
     }
 
-    private static @NotNull JobExecParam getJobExecParam(Map<String, String> 
paramValues) {
+    private JobExecParam getJobExecParam(Map<String, String> paramValues) {
         JobExecParam jobExecParam = new JobExecParam();
         jobExecParam.setPlaceholderValues(paramValues);
         return jobExecParam;

Reply via email to