3535 * The test works as follows:
3636 * 1. Start a large (reasonably long running) reindexing request on the coordinator-only node.
3737 * 2. Check that the reindexing task appears on the coordinating node
38- * 3. With a 10s timeout value for MAXIMUM_REINDEXING_TIMEOUT_SETTING,
38+ * 3. With a 60s timeout value for MAXIMUM_REINDEXING_TIMEOUT_SETTING,
3939 * wait for the reindexing task to complete before closing the node
4040 * 4. Confirm that the reindexing task succeeds with the wait (it will fail without it)
4141 */
@@ -58,8 +58,9 @@ public void testReindexWithShutdown() throws Exception {
5858 final String masterNodeName = internalCluster ().startMasterOnlyNode ();
5959 final String dataNodeName = internalCluster ().startDataOnlyNode ();
6060
61+ /* Maximum time to wait for reindexing tasks to complete before shutdown */
6162 final Settings COORD_SETTINGS = Settings .builder ()
62- .put (MAXIMUM_REINDEXING_TIMEOUT_SETTING .getKey (), TimeValue .timeValueSeconds (10 ))
63+ .put (MAXIMUM_REINDEXING_TIMEOUT_SETTING .getKey (), TimeValue .timeValueSeconds (60 ))
6364 .build ();
6465 final String coordNodeName = internalCluster ().startCoordinatingOnlyNode (Settings .EMPTY );
6566
@@ -118,7 +119,7 @@ public void onFailure(Exception e) {
118119 internalCluster ().stopNode (coordNodeName );
119120 }
120121
121- // Make sure all documents from the source index have been reindexed into the destination index
122+ // Make sure all documents from the source index have been re-indexed into the destination index
122123 private void checkDestinationIndex (String dataNodeName , int numDocs ) throws Exception {
123124 assertTrue (indexExists (DEST_INDEX ));
124125 flushAndRefresh (DEST_INDEX );
0 commit comments