commit

xpc

2024-01-30 cc9ebffc57e6343745cb1eadc47360d6107936bc

 product-server-data-center/src/main/java/com/product/data/center/service/DataArchivingService.java

@@ -390,6 +390,8 @@
            String maxID = paramFse.getString("max_id");
            String minID = paramFse.getString("min_id");
            String splitTableType = "1".equals(configFse.getString("split_table_type")) ? "1" : "0";
            //开启队列查询时，先清空队列防止上次未处理完的数据占用内存
            dataArchivingQueue.clear(sourceTable);
            dataArchivingQueue.query(sourceDbe, sourceTable, filterSb.toString(), null, uniqueField, minID);
            DataTableEntity allDte;
            Map<String, List<DataTableEntity>> groupDteMap;