You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/02/28 15:05:38 UTC
[incubator-seatunnel] branch dev updated: [SeaTunnel#1318] shouldn't check optional parameter in Hive sink (#1340)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 7ed1a6d [SeaTunnel#1318] shouldn't check optional parameter in Hive sink (#1340)
7ed1a6d is described below
commit 7ed1a6d87eb36aade5f5f50b2c038ca79cbc4650
Author: CenterCode <yx...@users.noreply.github.com>
AuthorDate: Mon Feb 28 23:05:32 2022 +0800
[SeaTunnel#1318] shouldn't check optional parameter in Hive sink (#1340)
---
.../src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala b/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala
index 1cbb2f3..92a2ae7 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala
+++ b/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala
@@ -29,7 +29,11 @@ import org.apache.spark.sql.{DataFrameWriter, Dataset, Row}
class Hive extends SparkBatchSink with Logging {
override def checkConfig(): CheckResult = {
- CheckConfigUtil.checkAllExists(config, "sql", "source_table_name", "result_table_name")
+ if (config.hasPath("sql")) {
+ CheckResult.success()
+ } else {
+ CheckConfigUtil.checkAllExists(config, "source_table_name", "result_table_name")
+ }
}
override def prepare(env: SparkEnvironment): Unit = {}