diff --git a/src/main/java/com/bfd/operate/process/EsInsertPorcess.java b/src/main/java/com/bfd/operate/process/EsInsertPorcess.java index 625c6f7..d8c55ec 100644 --- a/src/main/java/com/bfd/operate/process/EsInsertPorcess.java +++ b/src/main/java/com/bfd/operate/process/EsInsertPorcess.java @@ -143,9 +143,9 @@ public class EsInsertPorcess implements Runnable { //根据path去数据源data下获取字段值 Object value = DataUtil.getValue(valuePath, data); //字段为空不处理 - if (value == null || value.toString().trim().equals(Constants.EMPTY)) { - continue; - } +// if (value == null || value.toString().trim().equals(Constants.EMPTY)) { +// continue; +// } //字段类型 String dataType = (String) map.get(Constants.DATATYPE); //判断是不是 String类型 ---暂时先判断String类型