浏览代码

fix: 增量主要成员

许家凯 4 年之前
父节点
当前提交
6fa9a4295c
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/company_staff.scala

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

@@ -288,7 +288,7 @@ object company_staff {
            |        ) AS tmp
            |WHERE   tmp.c = 1
            |""".stripMargin).repartition(400)
-        .save2PhoenixByJDBC(s"COMPANY_STAFF", Seq("rowkey"
+        .save2PhoenixByJDBCPro(s"COMPANY_STAFF", Seq("rowkey"
           , "cid"
           , "hid"
           , "staff_type"