From a79772354be08d537737908e4189dbe4f1806f53 Mon Sep 17 00:00:00 2001 From: Mohammad Arshad Date: Mon, 9 Sep 2024 20:33:27 +0530 Subject: [PATCH] [Bug] [Seatunnel-web][Hive] Hive data source is not appearing in UI during the configuration of the Hive source. --- .../resources/connector-datasource-mapper.yaml | 18 +++++++++++++++++- .../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 0ba9a780f..9dabf7b69 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 31c37fb99..dca590731 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.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 paramValues) { + private JobExecParam getJobExecParam(Map paramValues) { JobExecParam jobExecParam = new JobExecParam(); jobExecParam.setPlaceholderValues(paramValues); return jobExecParam;