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/01/21 04:53:59 UTC
[incubator-seatunnel] branch dev updated: [SeaTunnel #1125][common] fix wrong code replace introduced in issue #1112 (#1126)
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 51f85c7 [SeaTunnel #1125][common] fix wrong code replace introduced in issue #1112 (#1126)
51f85c7 is described below
commit 51f85c72470127795a11a59cb479c203930d9728
Author: CenterCode <yx...@users.noreply.github.com>
AuthorDate: Fri Jan 21 12:53:50 2022 +0800
[SeaTunnel #1125][common] fix wrong code replace introduced in issue #1112 (#1126)
---
.../src/main/scala/org/apache/seatunnel/spark/sink/Config.scala | 1 -
.../src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala b/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala
index 7ee8bc0..859249b 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala
+++ b/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala
@@ -35,6 +35,5 @@ object Config extends Serializable {
val CHECK_INT_ERROR = "Please check bulk_size is larger than 0"
val CHECK_USER_ERROR = "Please check username and password at the same time"
- val CHECK_SUCCESS = "All check is success"
}
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala b/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala
index 9c13c15..91a4bbb 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala
+++ b/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala
@@ -92,7 +92,7 @@ class Doris extends SparkBatchSink with Serializable {
}
}
}
- CheckResult.error(Config.CHECK_SUCCESS)
+ CheckResult.success()
}
}