[Bug] [Seatunnel-web][Hive] Hive data source is not appearing in UI d…

…uring the configuration of the Hive source. (#211)
apache · Sep 10, 2024 · 1df50cf · 1df50cf
1 parent 783c078
commit 1df50cf
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 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
@@ -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
+        - MULTIPLE_TABLE
+
+    Hive:
+      businessMode:
+        - DATA_INTEGRATION
+      sceneMode:
+        - SINGLE_TABLE
diff --git a/...nnel-server/seatunnel-app/src/test/java/org/apache/seatunnel/app/utils/JobUtilsTests.java b/...nnel-server/seatunnel-app/src/test/java/org/apache/seatunnel/app/utils/JobUtilsTests.java
@@ -22,7 +22,6 @@
 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 void testReplaceJobConfigPlaceholders_NoDefaultValueThrowsException() {
 
         assertThrows(
                 SeatunnelException.class,
-                () -> {
-                    JobUtils.replaceJobConfigPlaceholders(jobConfigContent, jobExecParam);
-                });
+                () -> JobUtils.replaceJobConfigPlaceholders(jobConfigContent, jobExecParam));
     }
 
     @Test
@@ -112,7 +109,7 @@ public void testParseConfigWithPlaceHolders() {
         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;