@@ -76,7 +76,7 @@ public void testCreatePITSuccess() throws ExecutionException, InterruptedExcepti
76
76
request .setIndices (new String [] { "index" });
77
77
ActionFuture <CreatePitResponse > execute = client ().execute (CreatePitAction .INSTANCE , request );
78
78
CreatePitResponse pitResponse = execute .get ();
79
- PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime ());
79
+ PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime (), TimeValue . timeValueDays ( 1 ) );
80
80
assertSegments (false , client (), pitResponse .getId ());
81
81
client ().prepareIndex ("index" ).setId ("2" ).setSource ("field" , "value" ).setRefreshPolicy (IMMEDIATE ).get ();
82
82
SearchResponse searchResponse = client ().prepareSearch ("index" )
@@ -106,7 +106,7 @@ public void testCreatePITWithMultipleIndicesSuccess() throws ExecutionException,
106
106
107
107
ActionFuture <CreatePitResponse > execute = client ().execute (CreatePitAction .INSTANCE , request );
108
108
CreatePitResponse response = execute .get ();
109
- PitTestsUtil .assertUsingGetAllPits (client (), response .getId (), response .getCreationTime ());
109
+ PitTestsUtil .assertUsingGetAllPits (client (), response .getId (), response .getCreationTime (), TimeValue . timeValueDays ( 1 ) );
110
110
assertSegments (false , client (), response .getId ());
111
111
assertEquals (4 , response .getSuccessfulShards ());
112
112
assertEquals (4 , service .getActiveContexts ());
@@ -127,7 +127,7 @@ public void testCreatePITWithShardReplicasSuccess() throws ExecutionException, I
127
127
request .setIndices (new String [] { "index" });
128
128
ActionFuture <CreatePitResponse > execute = client ().execute (CreatePitAction .INSTANCE , request );
129
129
CreatePitResponse pitResponse = execute .get ();
130
- PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime ());
130
+ PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime (), TimeValue . timeValueDays ( 1 ) );
131
131
assertSegments (false , client (), pitResponse .getId ());
132
132
client ().prepareIndex ("index" ).setId ("2" ).setSource ("field" , "value" ).setRefreshPolicy (IMMEDIATE ).get ();
133
133
SearchResponse searchResponse = client ().prepareSearch ("index" )
@@ -229,7 +229,7 @@ public void testPitSearchOnCloseIndex() throws ExecutionException, InterruptedEx
229
229
request .setIndices (new String [] { "index" });
230
230
ActionFuture <CreatePitResponse > execute = client ().execute (CreatePitAction .INSTANCE , request );
231
231
CreatePitResponse pitResponse = execute .get ();
232
- PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime ());
232
+ PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime (), TimeValue . timeValueDays ( 1 ) );
233
233
assertSegments (false , client (), pitResponse .getId ());
234
234
SearchService service = getInstanceFromNode (SearchService .class );
235
235
assertEquals (2 , service .getActiveContexts ());
@@ -412,7 +412,7 @@ public void testPitAfterUpdateIndex() throws Exception {
412
412
request .setIndices (new String [] { "test" });
413
413
ActionFuture <CreatePitResponse > execute = client ().execute (CreatePitAction .INSTANCE , request );
414
414
CreatePitResponse pitResponse = execute .get ();
415
- PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime ());
415
+ PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime (), TimeValue . timeValueMinutes ( 2 ) );
416
416
SearchService service = getInstanceFromNode (SearchService .class );
417
417
418
418
assertThat (
@@ -570,7 +570,7 @@ public void testConcurrentSearches() throws Exception {
570
570
request .setIndices (new String [] { "index" });
571
571
ActionFuture <CreatePitResponse > execute = client ().execute (CreatePitAction .INSTANCE , request );
572
572
CreatePitResponse pitResponse = execute .get ();
573
- PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime ());
573
+ PitTestsUtil .assertUsingGetAllPits (client (), pitResponse .getId (), pitResponse .getCreationTime (), TimeValue . timeValueDays ( 1 ) );
574
574
assertSegments (false , client (), pitResponse .getId ());
575
575
Thread [] threads = new Thread [5 ];
576
576
CountDownLatch latch = new CountDownLatch (threads .length );
0 commit comments