Skip to content

Commit e697a61

Browse files
committed
iter
1 parent 84057fb commit e697a61

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

server/src/main/java/org/elasticsearch/action/search/TransportOpenPointInTimeAction.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,6 @@ protected void doExecute(Task task, OpenPointInTimeRequest request, ActionListen
192192
listener.onFailure(ex);
193193
return;
194194
}
195-
// TODO MP: collect indices and call execute open pit
196195
Set<String> collectedIndices = new HashSet<>(indices.length);
197196

198197
for (String remoteAlias : resolvedRemoteExpressions.keySet()) {
@@ -240,6 +239,9 @@ protected void doExecute(Task task, OpenPointInTimeRequest request, ActionListen
240239
terminalHandler.run();
241240
}));
242241
}
242+
} else {
243+
// for CPS requests that are targeting origin only, could be because of project_routing or other reasons.
244+
executeOpenPit((SearchTask) task, request, listener);
243245
}
244246
}
245247
} else {

0 commit comments

Comments
 (0)