会员标签4.0

src/main/java/com/gic/spark/tag/TagProcessManager.java

@@ -274,13 +274,10 @@ public class TagProcessManager {
                                                 }
                                                 return tagGroupInfoList.iterator();
                                             });
-        System.out.println("tagGroupInfoRDD.count==>"+tagGroupInfoRDD.count());
         SparkSession sparkSession=SparkEnvManager.getInstance().getSparkSession();
         Dataset<Row>tagGroupInfoDataset=sparkSession.createDataFrame(tagGroupInfoRDD,TagGroupInfo.class);
         tagGroupInfoDataset.createOrReplaceTempView("tag_group_info_tmp");
-        System.out.println("-------------tagGroupInfoDataset-------------");
-        tagGroupInfoDataset.show();
-//        sparkSession.sql(String.format("INSERT overwrite table %s.tag_group_info PARTITION(enterprise_id = '%s') SELECT id,tag_group_info from tag_group_info_tmp",isProduction?"tag4_prod":"tag4_test", enterpriseId));
+        sparkSession.sql(String.format("INSERT overwrite table %s.tag_group_info PARTITION(enterprise_id = '%s') SELECT id,tag_group_info from tag_group_info_tmp",isProduction?"tag4_prod":"tag4_test", enterpriseId));
 
     }