[incubator-seatunnel] branch dev updated: [Improvement][connector-spark-redis] Host and port are optional so removed existance check (#1857)

[we...@apache.org]

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

wenjun 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 a0744de8 [Improvement][connector-spark-redis] Host and port are optional so removed existance check (#1857)
a0744de8 is described below

commit a0744de83f6d37f053a1147f53ed6ef5a14ff042
Author: mans2singh <ma...@users.noreply.github.com>
AuthorDate: Thu May 12 10:23:24 2022 -0400

    [Improvement][connector-spark-redis] Host and port are optional so removed existance check (#1857)
---
 .../src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala
index b82304be..2bb53a83 100644
--- a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/redis/sink/Redis.scala
@@ -18,7 +18,7 @@
 package org.apache.seatunnel.spark.redis.sink
 
 import com.redislabs.provider.redis.{RedisConfig, RedisEndpoint, toRedisContext}
-import org.apache.seatunnel.common.config.{CheckConfigUtil, CheckResult}
+import org.apache.seatunnel.common.config.CheckResult
 import org.apache.seatunnel.shade.com.typesafe.config.ConfigFactory
 import org.apache.seatunnel.spark.SparkEnvironment
 import org.apache.seatunnel.spark.batch.SparkBatchSink
@@ -56,7 +56,6 @@ class Redis extends SparkBatchSink with Logging {
   }
 
   override def checkConfig(): CheckResult = {
-    CheckConfigUtil.checkAllExists(config, HOST, PORT)
     if (config.hasPath(DATA_TYPE)) {
       val dataType = config.getString(DATA_TYPE)
       val dataTypeList = List("KV", "HASH", "SET", "ZSET", "LIST")