会员标签4.0

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

@@ -278,7 +278,7 @@ public class TagProcessManager {
         conf.put("es.nodes", AppEnvUtil.ES_NODES);
         conf.put("es.mapping.date.rich", "false");
         conf.put("es.index.auto.create", "true");
-        conf.put("es.mapping.id", "memberId");
+        conf.put("es.mapping.id", "id");
         conf.put("es.write.operation", "upsert");
         conf.put("es.batch.size.bytes", "1024k");
         conf.put("es.batch.size.entries", "1500");