Skip to content

Commit bd8e666

Browse files
committed
Make deleteByQuery protected and remove built-in flush
1 parent c9d97be commit bd8e666

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3612,10 +3612,8 @@ protected long estimateMergeBytes(MergePolicy.OneMerge merge) {
36123612
}
36133613
}
36143614

3615-
public void deleteByQuery(ShardSplittingQuery query) throws Exception {
3616-
// System.out.println("Delete documents using ShardSplitQuery");
3615+
// Used to clean up unowned documents. Client-visible deletes should always be soft deletes.
3616+
protected void deleteByQuery(ShardSplittingQuery query) throws Exception {
36173617
indexWriter.deleteDocuments(query);
3618-
indexWriter.flush();
3619-
indexWriter.commit();
36203618
}
36213619
}

0 commit comments

Comments
 (0)