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;