Skip to content

Commit 2895f1e

Browse files
authored
[ML] Remove deprecated sort from reindex operation (#117606)
Sort in reindex is deprecated. This PR removes its use from within the reindexing step of dataframe analytics. Testing indicates that having the destination index sorted is a "nice to have" and not necessary for the DFA functionality to succeed.
1 parent 8350ff2 commit 2895f1e

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

docs/changelog/117606.yaml

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
pr: 117606
2+
summary: Remove deprecated sort from reindex operation within dataframe analytics procedure
3+
area: Machine Learning
4+
type: enhancement
5+
issues: []

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/dataframe/steps/ReindexingStep.java

-3
Original file line numberDiff line numberDiff line change
@@ -27,13 +27,11 @@
2727
import org.elasticsearch.core.Nullable;
2828
import org.elasticsearch.core.TimeValue;
2929
import org.elasticsearch.index.IndexNotFoundException;
30-
import org.elasticsearch.index.mapper.SeqNoFieldMapper;
3130
import org.elasticsearch.index.reindex.BulkByScrollResponse;
3231
import org.elasticsearch.index.reindex.BulkByScrollTask;
3332
import org.elasticsearch.index.reindex.ReindexAction;
3433
import org.elasticsearch.index.reindex.ReindexRequest;
3534
import org.elasticsearch.script.Script;
36-
import org.elasticsearch.search.sort.SortOrder;
3735
import org.elasticsearch.tasks.Task;
3836
import org.elasticsearch.tasks.TaskCancelledException;
3937
import org.elasticsearch.tasks.TaskId;
@@ -147,7 +145,6 @@ protected void doExecute(ActionListener<StepResponse> listener) {
147145
reindexRequest.setSourceQuery(config.getSource().getParsedQuery());
148146
reindexRequest.getSearchRequest().allowPartialSearchResults(false);
149147
reindexRequest.getSearchRequest().source().fetchSource(config.getSource().getSourceFiltering());
150-
reindexRequest.getSearchRequest().source().sort(SeqNoFieldMapper.NAME, SortOrder.ASC);
151148
reindexRequest.setDestIndex(config.getDest().getIndex());
152149

153150
// We explicitly set slices to 1 as we cannot parallelize in order to have the incremental id

0 commit comments

Comments
 (0)