From b629497905821acf3f4ad7d7ac2b2e298da916ed Mon Sep 17 00:00:00 2001 From: bojackli <478378663@qq.com> Date: Thu, 11 Apr 2024 10:25:46 +0800 Subject: [PATCH 1/2] update hive_datasource.conf --- conf-template/client_import/hive_datasource.conf | 2 +- conf-template/sst_import/hive_datasource.conf | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/conf-template/client_import/hive_datasource.conf b/conf-template/client_import/hive_datasource.conf index 2b2c6e26..979c8fb4 100644 --- a/conf-template/client_import/hive_datasource.conf +++ b/conf-template/client_import/hive_datasource.conf @@ -5,7 +5,7 @@ # --driver-memory=2G --executor-memory=30G \ # --num-executors=3 --executor-cores=20 \ # --class com.vesoft.nebula.exchange.Exchange \ -# nebula-exchange-3.0-SNAPSHOT.jar -c csv_datasource.conf +# nebula-exchange-3.0-SNAPSHOT.jar -c hive_datasource.conf { # Spark config diff --git a/conf-template/sst_import/hive_datasource.conf b/conf-template/sst_import/hive_datasource.conf index fdbbc0e0..137cbd92 100644 --- a/conf-template/sst_import/hive_datasource.conf +++ b/conf-template/sst_import/hive_datasource.conf @@ -5,7 +5,7 @@ # --driver-memory=2G --executor-memory=30G \ # --num-executors=3 --executor-cores=20 \ # --class com.vesoft.nebula.exchange.Exchange \ -# nebula-exchange-3.0-SNAPSHOT.jar -c csv_datasource.conf +# nebula-exchange-3.0-SNAPSHOT.jar -c hive_datasource.conf { # Spark config From 7d3f179e6e231cde5bb1abe54c9a8078489430d7 Mon Sep 17 00:00:00 2001 From: bojackli <478378663@qq.com> Date: Tue, 16 Apr 2024 14:15:17 +0800 Subject: [PATCH 2/2] fix typo --- .../main/scala/com/vesoft/exchange/common/config/Configs.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala index 6224f62b..dfb4b035 100644 --- a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala +++ b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala @@ -109,7 +109,7 @@ case class UserConfigEntry(user: String, password: String) { case class ConnectionConfigEntry(timeout: Int, retry: Int) { require(timeout > 0 && retry > 0, "connection timeout or retry must be larger than 0") - override def toString: String = s"cConnectionConfigEntry:{timeout:$timeout, retry:$retry}" + override def toString: String = s"ConnectionConfigEntry:{timeout:$timeout, retry:$retry}" } /**