去除单独标签

src/main/scala/com/winhc/bigdata/spark/ng/relation/inc_company_relation_v2.scala

@@ -486,21 +486,21 @@ case class inc_company_relation_v2(s: SparkSession,
          |where ds = '$ds'
          |""".stripMargin).show(20, false)
 
-    //新增或者更新-投资人-打标签
-    sql(
-      s"""
-         |INSERT ${if (isWindows) "INTO" else "OVERWRITE"} table $inc_ads_person_node_label_kafka  PARTITION (ds='$ds')
-         |select key,max(message) message
-         |from
-         |(
-         |  select
-         |  start_id key,
-         |  get_person_node(start_id, start_name, deleted, '7') message
-         |  from $inc_ads_relation_holder
-         |  where ds = '$ds' and holder_type = 1
-         |)
-         |group by key
-         |""".stripMargin).show(20, false)
+//    //新增或者更新-投资人-打标签
+//    sql(
+//      s"""
+//         |INSERT ${if (isWindows) "INTO" else "OVERWRITE"} table $inc_ads_person_node_label_kafka  PARTITION (ds='$ds')
+//         |select key,max(message) message
+//         |from
+//         |(
+//         |  select
+//         |  start_id key,
+//         |  get_person_node(start_id, start_name, deleted, '7') message
+//         |  from $inc_ads_relation_holder
+//         |  where ds = '$ds' and holder_type = 1
+//         |)
+//         |group by key
+//         |""".stripMargin).show(20, false)
 
     //防止空分区
     addEmptyPartitionOrSkip(inc_ads_company_node_kafka, ds)