|
@@ -149,7 +149,6 @@ public class DWIndexFrameServiceImpl implements DWIndexFrameService {
|
|
|
List<CompletableFuture<List<TDampDwIndexData>>> futures = new ArrayList<>();
|
|
|
for (int i = 0; i < chunk; i++) {
|
|
|
int pars = i;
|
|
|
- System.out.println(pars);
|
|
|
CompletableFuture<List<TDampDwIndexData>> future = CompletableFuture.supplyAsync(() -> {
|
|
|
try {
|
|
|
return tDampDwIndexDataService.queryAllByLimit(indexCode, pars * ETAConstants.ETA_PUSH_DATA_LIMIT, ETAConstants.ETA_PUSH_DATA_LIMIT);
|