commit

T100738

2024-04-16 eeb86aaf2f73a02600195ce2637dde6caf858a88

 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;