许家凯 4 years ago
parent
commit
d4ec5db2e9

+ 1 - 3
src/main/scala/com/winhc/bigdata/spark/jobs/CompanyIncCompany2Es.scala

@@ -69,7 +69,7 @@ object CompanyIncCompany2Es {
     , "DELETED"
   )
   val outFields_Human = Seq(
-    ,"NEW_CID"
+    "NEW_CID"
     ,"CID"
     ,"ID"
     ,"COMPANY_NAME"
@@ -206,8 +206,6 @@ object CompanyIncCompany2Es {
            |FROM
            |    tmp_company_human_relation_inc
            |""".stripMargin)
-
-      import spark.implicits._
       //写出到hbase
       import org.apache.spark.sql.functions.col
       val jobConf = HBaseConfig.HBaseOutputJobConf("COMPANY_HUMAN_RELATION")