会员标签4.0

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

@@ -92,6 +92,7 @@ public class TagProcessManager {
         memberSharding4Datasource = new DataSourceSharding(AppEnvUtil.MEMBER_SHARDING_4, ConstantUtil.TAB_ENTERPRISE_USER);
 
         List<TabSceneCrowd> sceneCrowdList=member4RddManager.getPojo("tab_scene_crowd", TabSceneCrowd.class,null)
+                                                                .filter(new Column("delete_flag").equalTo(0))
                                                                 .filter(new Column("valid_flag").equalTo(1))
                                                                 .filter(new Column("real_time").equalTo(2))
                                                                 .collectAsList();