From fda72667cb2ba2b2a8bafa2817c72b27c19a71cd Mon Sep 17 00:00:00 2001 From: markilue <745518019@qq.com> Date: Mon, 16 May 2022 13:43:34 +0800 Subject: [PATCH] =?UTF-8?q?=E7=94=A8=E6=88=B7=E7=94=BB=E5=83=8Fexample?= =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scala/com/atguigu/userprofile/app/TaskExportCkApp.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Big_data_example/user_profile/export-clickhouse/src/main/scala/com/atguigu/userprofile/app/TaskExportCkApp.scala b/Big_data_example/user_profile/export-clickhouse/src/main/scala/com/atguigu/userprofile/app/TaskExportCkApp.scala index 61db13e..8f8ac2c 100644 --- a/Big_data_example/user_profile/export-clickhouse/src/main/scala/com/atguigu/userprofile/app/TaskExportCkApp.scala +++ b/Big_data_example/user_profile/export-clickhouse/src/main/scala/com/atguigu/userprofile/app/TaskExportCkApp.scala @@ -23,7 +23,7 @@ object TaskExportCkApp{ def main(args: Array[String]): Unit = { //TODO 1 读取hive的宽表 读取成为Dataframe - val sparkConf: SparkConf = new SparkConf().setAppName("task_export_app") .setMaster("local[*]") + val sparkConf: SparkConf = new SparkConf().setAppName("task_export_app") //.setMaster("local[*]") val sparkSession: SparkSession = SparkSession.builder().config(sparkConf).enableHiveSupport().getOrCreate() val taskDate =args(1);