会员标签4.0

src/main/java/com/gic/spark/SparkTagProcess.java

@@ -24,7 +24,7 @@ public class SparkTagProcess {
         boolean extractData = Boolean.parseBoolean(args[1]);
         ShardingConfigManager.initDefualt();
         SparkEnvManager.getInstance().init("member_tag_4.0");
-        SparkConfigManager.getInstance().init(isProd ? SparkConfigManager.EnvType.PRO : SparkConfigManager.EnvType.DEV, null);
+        SparkConfigManager.getInstance().init(SparkConfigManager.EnvType.PRO, null);
         TagProcessManager.getInstance().init(isProd);
         TagProcessManager.getInstance().process(extractData);
     }

src/main/java/com/gic/spark/SparkTagProcessByEnterpriseOrId.java

@@ -35,7 +35,7 @@ public class SparkTagProcessByEnterpriseOrId {
         }
         ShardingConfigManager.initDefualt();
         SparkEnvManager.getInstance().init("member_tag_4.0");
-        SparkConfigManager.getInstance().init(isProd ? SparkConfigManager.EnvType.PRO : SparkConfigManager.EnvType.DEV, null);
+        SparkConfigManager.getInstance().init(SparkConfigManager.EnvType.PRO, null);
         TagProcessManager.getInstance().init(isProd);
         if(type.equals("enterprise")){
             TagProcessManager.getInstance().setEnterpriseId(params);
@@ -44,6 +44,6 @@ public class SparkTagProcessByEnterpriseOrId {
         }else{
             return;
         }
-//        TagProcessManager.getInstance().process(extractData);
+        TagProcessManager.getInstance().process(extractData);
     }
 }