11

src/main/java/com/qingjian/common/utils/LuceneManager.java

@@ -131,8 +131,8 @@ public class LuceneManager {
         if (ramDocCount > 0) {
             logger.info("开始强制合并段，当前内存文档数: {}", ramDocCount);
             writer.forceMerge(1);
-            logger.info("段合并完成");
         }
+        logger.info("段合并完成");
     }
 
     /**

src/main/java/com/qingjian/module/dm/clean/AbstractDataLoader.java

@@ -38,8 +38,7 @@ public abstract class AbstractDataLoader<S, T extends Cleaned> implements DataLo
         T t = convert(record);
         long l = System.currentTimeMillis();
         fillData(t);
-        log.info("写入 fillData 成功, tableName={}, cost={}", tableName, System.currentTimeMillis() - l);
-        //doWrite(t);
+        doWrite(t);
     }
 
     @Override