Skip to content

Commit ad4219c

Browse files
committed
Add keepalive to second and third query
1 parent 730efd4 commit ad4219c

File tree

1 file changed

+2
-2
lines changed
  • x-pack/plugin/searchable-snapshots/src/internalClusterTest/java/org/elasticsearch/xpack/searchablesnapshots

1 file changed

+2
-2
lines changed

x-pack/plugin/searchable-snapshots/src/internalClusterTest/java/org/elasticsearch/xpack/searchablesnapshots/RetrySearchIntegTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,7 @@ public void testRetryPointInTime() throws Exception {
183183
assertNoFailuresAndResponse(
184184
prepareSearch().setSearchType(SearchType.QUERY_THEN_FETCH)
185185
.setAllowPartialSearchResults(randomBoolean()) // partial results should not matter here
186-
.setPointInTime(new PointInTimeBuilder(pitId)),
186+
.setPointInTime(new PointInTimeBuilder(pitId).setKeepAlive(TimeValue.timeValueMinutes(2))),
187187
resp -> {
188188
assertHitCount(resp, docCount);
189189
updatedPit.set(resp.pointInTimeId());
@@ -204,7 +204,7 @@ public void testRetryPointInTime() throws Exception {
204204
.setSearchType(SearchType.QUERY_THEN_FETCH)
205205
.setPreFilterShardSize(between(1, 10))
206206
.setAllowPartialSearchResults(randomBoolean()) // partial results should not matter here
207-
.setPointInTime(new PointInTimeBuilder(updatedPit.get())),
207+
.setPointInTime(new PointInTimeBuilder(updatedPit.get()).setKeepAlive(TimeValue.timeValueMinutes(2))),
208208
resp -> {
209209
assertThat(resp.pointInTimeId(), equalTo(updatedPit.get()));
210210
assertHitCount(resp, docCount);

0 commit comments

Comments
 (0)