会员标签4.0

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

@@ -238,6 +238,7 @@ public class TagProcessManager {
                                                                                 return result.iterator();
                                                                             });
 
+                System.out.println("updateMemberGroupRdd==>"+updateMemberGroupRdd.count());
                 JavaPairRDD<Long,String>cacheMemberGroupRdd=updateMemberGroupRdd.cache();
 
                 updateIndex(cacheMemberGroupRdd,enterpriseId);