{
  "error": {
    "root_cause": [{
      "type": "illegal_argument_exception",
      "reason": "Result window is too large, from + size must be <= 10000"
    }]
  }
}

# 動(dòng)態(tài)修改索引配置（需保留原有設(shè)置）
PUT /your_index/_settings?preserve_existing=true
{
  "index": {
    "max_result_window": "20000"  # 設(shè)置為更大的值
  }
}

public JSONArray scrollQuery(JSONObject params) {
    JSONArray result = new JSONArray();
    String scrollId = null;
    
    try {
        // 初始化滾動(dòng)查詢（保持 10 分鐘快照）
        SearchRequest searchRequest = new SearchRequest("logs");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.size(1000);
        sourceBuilder.query(QueryBuilders.matchAllQuery());
        
        searchRequest.source(sourceBuilder);
        searchRequest.scroll(TimeValue.timeValueMinutes(10));
        
        // 首次查詢獲取 scroll_id
        SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
        scrollId = response.getScrollId();
        result.addAll(Arrays.asList(response.getHits().getHits()));
        
        // 持續(xù)拉取數(shù)據(jù)
        while (true) {
            SearchScrollRequest scrollRequest = new SearchScrollRequest(scrollId);
            scrollRequest.scroll(TimeValue.timeValueMinutes(10));
            response = client.scroll(scrollRequest, RequestOptions.DEFAULT);
            
            if (response.getHits().getHits().length == 0) break;
            result.addAll(Arrays.asList(response.getHits().getHits()));
            scrollId = response.getScrollId();
        }
    } finally {
        // 清理上下文（必須操作）
        if (scrollId != null) {
            ClearScrollRequest clearRequest = new ClearScrollRequest();
            clearRequest.addScrollId(scrollId);
            client.clearScroll(clearRequest, RequestOptions.DEFAULT);
        }
    }
    return result;
}

java
public JSONObject searchData(JSONObject queryConditionsParam) {
    int pageSize = queryConditionsParam.getInt("pageSize");
    double[] searchAfter = null;
    
    // 提取游標(biāo)參數(shù)（上一頁最后一個(gè)文檔的排序值）
    if (queryConditionsParam.containsKey("search_after")) {
        JSONArray searchAfterArray = queryConditionsParam.getJSONArray("search_after");
        searchAfter = searchAfterArray.toDoubleArray();
    }

    SearchRequest searchRequest = new SearchRequest("my_log");
    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

    // 關(guān)鍵配置：排序字段必須與 search_after 對(duì)應(yīng)
    sourceBuilder.sort("created_start_time", SortOrder.DESC);
    if (searchAfter != null) {
        sourceBuilder.searchAfter(searchAfter);
    }
    sourceBuilder.size(pageSize); // 無需設(shè)置 from 參數(shù)

    // 構(gòu)建查詢條件（示例：按日志ID過濾）
    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    boolQueryBuilder.must(QueryBuilders.termQuery("log_id", queryConditionsParam.getInt("log_id")));
    // 其他復(fù)雜條件可在此追加...

    sourceBuilder.query(boolQueryBuilder);
    searchRequest.source(sourceBuilder);

    try {
        SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
        return buildResult(response); // 封裝結(jié)果并返回游標(biāo)
    } catch (IOException e) {
        log.error("ES查詢失敗", e);
        throw new RuntimeException("查詢異常");
    }
}

// 結(jié)果封裝方法：提取游標(biāo)并返回下一頁參數(shù)
private JSONObject buildResult(SearchResponse response) {
    JSONObject result = new JSONObject();
    JSONArray hits = new JSONArray();
    double[] nextCursor = null;

    for (SearchHit hit : response.getHits()) {
        hits.add(new JSONObject(hit.getSourceAsString()));
        // 提取排序字段值作為下一頁游標(biāo)
        if (hit.getSortValues().length > 0) {
            nextCursor = Arrays.stream(hit.getSortValues())
                              .mapToDouble(Double::valueOf)
                              .toArray();
        }
    }

    result.put("data", hits);
    result.put("totalCount", response.getHits().getTotalHits().value);
    if (nextCursor != null) {
        result.put("search_after", nextCursor); // 返回游標(biāo)供下次查詢
    }
    return result;
}