fix: job

src/main/java/com/winhc/bigdata/task/util/EsFastScan.java

@@ -26,8 +26,6 @@ import java.util.function.Consumer;
  */
 @Slf4j
 public class EsFastScan {
-    private final Scroll scroll = new Scroll(TimeValue.timeValueMinutes(3L));
-
     private RestHighLevelClient client;
     private Consumer<SearchHit[]> func;
     private String index;
@@ -78,7 +76,7 @@ public class EsFastScan {
                 new ThreadPoolExecutor.CallerRunsPolicy()
         );
 
-
+        Scroll scroll = new Scroll(TimeValue.timeValueMinutes(3L));
         SearchRequest searchRequest = new SearchRequest(index).types(type).scroll(scroll);
 
         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(batchSize);
@@ -121,7 +119,7 @@ public class EsFastScan {
 
     @SneakyThrows
     private int scanData(ThreadPoolExecutor executorService, String scrollId) {
-        SearchScrollRequest scroll = new SearchScrollRequest(scrollId);
+        SearchScrollRequest scroll = new SearchScrollRequest(scrollId).scroll(new Scroll(TimeValue.timeValueMinutes(3L)));
         SearchResponse searchResponse = client.scroll(scroll, RequestOptions.DEFAULT);
         int num = searchResponse.getHits().getHits().length;
         if (num == 0) {