会员标签4.0

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

@@ -274,6 +274,7 @@ 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");