fix: 动态发布生产

src/main/scala/com/winhc/bigdata/spark/ng/change/NgChangeExtractAll.scala

@@ -2,12 +2,12 @@ package com.winhc.bigdata.spark.ng.change
 
 import com.winhc.bigdata.spark.config.EsConfig
 import com.winhc.bigdata.spark.utils.BaseUtil.{getYesterday, isWindows}
-import com.winhc.bigdata.spark.utils.{AsyncExtract, BaseUtil, LoggingUtils, ReflectUtils, SparkUtils}
+import com.winhc.bigdata.spark.utils._
 import org.apache.commons.lang3.StringUtils
 import org.apache.spark.internal.Logging
-import org.apache.spark.sql.{Row, SparkSession}
 import org.apache.spark.sql.functions.col
 import org.apache.spark.sql.types.{MapType, StringType, StructField, StructType}
+import org.apache.spark.sql.{Row, SparkSession}
 
 import scala.annotation.meta.getter
 import scala.collection.mutable

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/NgCompanyDynamic.scala

@@ -198,7 +198,7 @@ object NgCompanyDynamic {
     )
     val spark = SparkUtils.InitEnv(this.getClass.getSimpleName, config)
 
-//    val tn = "company,company_staff,company_holder"
+    //    val tn = "company,company_staff,company_holder"
     val tn = "all"
     var dynamicArgs = NgCompanyDynamicArgs.getStartArgs(inc)
     var aggArgs = NgCompanyDynamicArgs.getAggArgs