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);