Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -615,7 +615,6 @@ private IndexDocFailureStoreStatus processFailure(BulkItemRequest bulkItemReques
* @return a data stream if the write request points to a data stream, or {@code null} if it does not
*/
private static DataStream getRedirectTargetCandidate(DocWriteRequest<?> docWriteRequest, ProjectMetadata project) {
// PRTODO: We could check for cluster feature here instead
// If there is no index abstraction, then the request is using a pattern of some sort, which data streams do not support
IndexAbstraction ia = project.getIndicesLookup().get(docWriteRequest.index());
return DataStream.resolveDataStream(ia, project);
Expand Down