修改了逻辑

src/main/scala/com/data/SyncDoctorOrganizationDepartment.scala

@@ -22,7 +22,6 @@ class SyncDoctorOrganizationDepartment {
 
 }
 
-
 object SyncDoctorOrganizationDepartment {
 	def main(args: Array[String]): Unit = {
 		//1.执行任务之前先往record表记录
@@ -97,6 +96,7 @@ object SyncDoctorOrganizationDepartment {
 			//导入到表中
 			sparkSession.sql(s"load data INPATH '${SyncDataConfig.PARQUET_PATH}${SyncDataConfig.DATABASE1}.${SyncDataConfig.Hive_TABLE3}' " +
 				s"overwrite into table ${SyncDataConfig.DATABASE1}.${SyncDataConfig.Hive_TABLE3}")
+
 			//更新record表
 			println("-------------------------更新 schedule_job_record表--------------------------------------")
 			//任务结束,更新 record 配置表