@@ -469,7 +469,7 @@ public void testWaitForAliasCreationMultipleShards() throws Exception {
469
469
assertThat (clusterHealth .getStatus (), equalTo (ClusterHealthStatus .GREEN ));
470
470
471
471
for (int i = 0 ; i < 10 ; i ++) {
472
- assertThat (client1 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias" + i ).execute ().actionGet ().acknowledged (), equalTo (true ));
472
+ assertThat (client1 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias" + i ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
473
473
client2 .index (indexRequest ("alias" + i ).type ("type1" ).id ("1" ).source (source ("1" , "test" )).refresh (true )).actionGet ();
474
474
}
475
475
@@ -490,7 +490,7 @@ public void testWaitForAliasCreationSingleShard() throws Exception {
490
490
assertThat (clusterHealth .getStatus (), equalTo (ClusterHealthStatus .GREEN ));
491
491
492
492
for (int i = 0 ; i < 10 ; i ++) {
493
- assertThat (getClient ().admin ().indices ().prepareAliases ().addAlias ("test" , "alias" + i ).execute ().actionGet ().acknowledged (), equalTo (true ));
493
+ assertThat (getClient ().admin ().indices ().prepareAliases ().addAlias ("test" , "alias" + i ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
494
494
getClient ().index (indexRequest ("alias" + i ).type ("type1" ).id ("1" ).source (source ("1" , "test" )).refresh (true )).actionGet ();
495
495
}
496
496
}
@@ -516,7 +516,7 @@ public void testWaitForAliasSimultaneousUpdate() throws Exception {
516
516
executor .submit (new Runnable () {
517
517
@ Override
518
518
public void run () {
519
- assertThat (client1 .admin ().indices ().prepareAliases ().addAlias ("test" , aliasName ).execute ().actionGet ().acknowledged (), equalTo (true ));
519
+ assertThat (client1 .admin ().indices ().prepareAliases ().addAlias ("test" , aliasName ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
520
520
client2 .index (indexRequest (aliasName ).type ("type1" ).id ("1" ).source (source ("1" , "test" )).refresh (true )).actionGet ();
521
521
}
522
522
});
@@ -544,27 +544,27 @@ public void testSameAlias() throws Exception {
544
544
assertThat (clusterHealth .getStatus (), equalTo (ClusterHealthStatus .GREEN ));
545
545
546
546
logger .info ("--> creating alias1 " );
547
- assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" ).execute ().actionGet ().acknowledged (), equalTo (true ));
547
+ assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
548
548
TimeValue timeout = TimeValue .timeValueSeconds (2 );
549
549
logger .info ("--> recreating alias1 " );
550
550
StopWatch stopWatch = new StopWatch ();
551
551
stopWatch .start ();
552
- assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" ).setTimeout (timeout ).execute ().actionGet ().acknowledged (), equalTo (true ));
552
+ assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" ).setTimeout (timeout ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
553
553
assertThat (stopWatch .stop ().lastTaskTime ().millis (), lessThan (timeout .millis ()));
554
554
555
555
logger .info ("--> modifying alias1 to have a filter" );
556
556
stopWatch .start ();
557
- assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" , termFilter ("name" , "foo" )).setTimeout (timeout ).execute ().actionGet ().acknowledged (), equalTo (true ));
557
+ assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" , termFilter ("name" , "foo" )).setTimeout (timeout ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
558
558
assertThat (stopWatch .stop ().lastTaskTime ().millis (), lessThan (timeout .millis ()));
559
559
560
560
logger .info ("--> recreating alias1 with the same filter" );
561
561
stopWatch .start ();
562
- assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" , termFilter ("name" , "foo" )).setTimeout (timeout ).execute ().actionGet ().acknowledged (), equalTo (true ));
562
+ assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" , termFilter ("name" , "foo" )).setTimeout (timeout ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
563
563
assertThat (stopWatch .stop ().lastTaskTime ().millis (), lessThan (timeout .millis ()));
564
564
565
565
logger .info ("--> recreating alias1 with a different filter" );
566
566
stopWatch .start ();
567
- assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" , termFilter ("name" , "bar" )).setTimeout (timeout ).execute ().actionGet ().acknowledged (), equalTo (true ));
567
+ assertThat (client2 .admin ().indices ().prepareAliases ().addAlias ("test" , "alias1" , termFilter ("name" , "bar" )).setTimeout (timeout ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
568
568
assertThat (stopWatch .stop ().lastTaskTime ().millis (), lessThan (timeout .millis ()));
569
569
570
570
logger .info ("--> verify that filter was updated" );
@@ -573,12 +573,12 @@ public void testSameAlias() throws Exception {
573
573
574
574
logger .info ("--> deleting alias1" );
575
575
stopWatch .start ();
576
- assertThat (client2 .admin ().indices ().prepareAliases ().removeAlias ("test" , "alias1" ).setTimeout (timeout ).execute ().actionGet ().acknowledged (), equalTo (true ));
576
+ assertThat (client2 .admin ().indices ().prepareAliases ().removeAlias ("test" , "alias1" ).setTimeout (timeout ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
577
577
assertThat (stopWatch .stop ().lastTaskTime ().millis (), lessThan (timeout .millis ()));
578
578
579
579
logger .info ("--> deleting alias1 one more time" );
580
580
stopWatch .start ();
581
- assertThat (client2 .admin ().indices ().prepareAliases ().removeAlias ("test" , "alias1" ).setTimeout (timeout ).execute ().actionGet ().acknowledged (), equalTo (true ));
581
+ assertThat (client2 .admin ().indices ().prepareAliases ().removeAlias ("test" , "alias1" ).setTimeout (timeout ).execute ().actionGet ().isAcknowledged (), equalTo (true ));
582
582
assertThat (stopWatch .stop ().lastTaskTime ().millis (), lessThan (timeout .millis ()));
583
583
}
584
584
0 commit comments