会员标签4.0

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

@@ -88,7 +88,6 @@ public class TagProcess {
                                                                 .filter(new Column("real_time").equalTo(2));
         List<TabSceneCrowd> sceneCrowdList=sceneCrowdDataset.collectAsList();
         for(TabSceneCrowd sceneCrowd:sceneCrowdList){
-            System.out.println("sceneCrowd==>"+JSONObject.toJSONString(sceneCrowd));
             LinkedList<TagConditionGroupDTO>conditionGroupDTOList=JSONObject.parseObject(sceneCrowd.getTag_Condition_Group_Info(),  new TypeReference<LinkedList<TagConditionGroupDTO>>(){});
             sceneCrowdDTOList.add(new SceneCrowdDTO(sceneCrowd,conditionGroupDTOList));
         }
@@ -157,7 +156,7 @@ public class TagProcess {
             DataSourceManager.getInstance().addSourceEntity(memberDatasource,enterpriseTagEntry.getKey().intValue());
         }
 
-        if (extractData) {
+/*        if (extractData) {
             DataSourceManager.getInstance().init(isProduction);
             DataSourceManager.getInstance().extractDataToDatabase();
             DingtalkMessageUtil.sendAlertMessage("extractData to hive finish !");
@@ -217,7 +216,7 @@ public class TagProcess {
 
                 cacheMemberGroupRdd.unpersist();
             }
-        }
+        }*/
 
 
     }