@@ -128,8 +128,7 @@ public void testSecurityNativeRealm() throws Exception {
128
128
Map <?, ?> settingsMap = (Map <?, ?>) indexSettingsMap .get ("settings" );
129
129
logger .info ("settings map {}" , settingsMap );
130
130
if (settingsMap .containsKey ("index" )) {
131
- @ SuppressWarnings ("unchecked" )
132
- int format = Integer .parseInt (String .valueOf (((Map <String , Object >)settingsMap .get ("index" )).get ("format" )));
131
+ int format = Integer .parseInt (String .valueOf (((Map <?, ?>)settingsMap .get ("index" )).get ("format" )));
133
132
assertEquals ("The security index needs to be upgraded" , SECURITY_EXPECTED_INDEX_FORMAT_VERSION , format );
134
133
}
135
134
}
@@ -497,7 +496,6 @@ private void assertOldTemplatesAreDeleted() throws IOException {
497
496
assertThat (templates .keySet (), not (hasItems (is ("watches" ), startsWith ("watch-history" ), is ("triggered_watches" ))));
498
497
}
499
498
500
- @ SuppressWarnings ("unchecked" )
501
499
private void assertWatchIndexContentsWork () throws Exception {
502
500
// Fetch a basic watch
503
501
Request getRequest = new Request ("GET" , "_watcher/watch/bwc_watch" );
@@ -521,7 +519,7 @@ private void assertWatchIndexContentsWork() throws Exception {
521
519
logger .error ("-----> {}" , bwcWatch );
522
520
523
521
assertThat (bwcWatch .get ("found" ), equalTo (true ));
524
- Map <String , Object > source = (Map <String , Object >) bwcWatch .get ("watch" );
522
+ Map <?, ? > source = (Map <?, ? >) bwcWatch .get ("watch" );
525
523
assertEquals (1000 , source .get ("throttle_period_in_millis" ));
526
524
int timeout = (int ) timeValueSeconds (100 ).millis ();
527
525
assertThat (ObjectPath .eval ("input.search.timeout_in_millis" , source ), equalTo (timeout ));
@@ -547,7 +545,7 @@ private void assertWatchIndexContentsWork() throws Exception {
547
545
}
548
546
bwcWatch = entityAsMap (client ().performRequest (getRequest ));
549
547
assertThat (bwcWatch .get ("found" ), equalTo (true ));
550
- source = (Map <String , Object >) bwcWatch .get ("watch" );
548
+ source = (Map <?, ? >) bwcWatch .get ("watch" );
551
549
assertEquals (timeout , source .get ("throttle_period_in_millis" ));
552
550
assertThat (ObjectPath .eval ("actions.index_payload.throttle_period_in_millis" , source ), equalTo (timeout ));
553
551
@@ -557,11 +555,11 @@ private void assertWatchIndexContentsWork() throws Exception {
557
555
*/
558
556
bwcWatch = entityAsMap (client ().performRequest (new Request ("GET" , "_watcher/watch/bwc_funny_timeout" )));
559
557
assertThat (bwcWatch .get ("found" ), equalTo (true ));
560
- source = (Map <String , Object >) bwcWatch .get ("watch" );
558
+ source = (Map <?, ? >) bwcWatch .get ("watch" );
561
559
562
560
563
561
Map <String , Object > attachments = ObjectPath .eval ("actions.work.email.attachments" , source );
564
- Map <String , Object > attachment = (Map <String , Object >) attachments .get ("test_report.pdf" );
562
+ Map <?, ? > attachment = (Map <?, ? >) attachments .get ("test_report.pdf" );
565
563
Map <String , Object > request = ObjectPath .eval ("http.request" , attachment );
566
564
assertEquals (timeout , request .get ("read_timeout_millis" ));
567
565
assertEquals ("https" , request .get ("scheme" ));
@@ -577,8 +575,8 @@ private void assertWatchIndexContentsWork() throws Exception {
577
575
searchRequest .addParameter (RestSearchAction .TOTAL_HITS_AS_INT_PARAM , "true" );
578
576
}
579
577
Map <String , Object > history = entityAsMap (client ().performRequest (searchRequest ));
580
- Map <String , Object > hits = (Map <String , Object >) history .get ("hits" );
581
- assertThat ((int ) (hits .get ("total" )), greaterThanOrEqualTo (2 ));
578
+ Map <?, ? > hits = (Map <?, ? >) history .get ("hits" );
579
+ assertThat ((Integer ) (hits .get ("total" )), greaterThanOrEqualTo (2 ));
582
580
}
583
581
584
582
private void assertBasicWatchInteractions () throws Exception {
@@ -601,7 +599,7 @@ private void assertBasicWatchInteractions() throws Exception {
601
599
602
600
Map <String , Object > get = entityAsMap (client ().performRequest (new Request ("GET" , "_watcher/watch/new_watch" )));
603
601
assertThat (get .get ("found" ), equalTo (true ));
604
- @ SuppressWarnings ( "unchecked" ) Map <?, ?> source = (Map <String , Object >) get .get ("watch" );
602
+ Map <?, ?> source = (Map <?, ? >) get .get ("watch" );
605
603
Map <String , Object > logging = ObjectPath .eval ("actions.awesome.logging" , source );
606
604
assertEquals ("info" , logging .get ("level" ));
607
605
assertEquals ("test" , logging .get ("text" ));
@@ -689,7 +687,7 @@ private void assertUserInfo(final boolean oldCluster) throws Exception {
689
687
final String user = oldCluster ? "preupgrade_user" : "postupgrade_user" ;
690
688
Request request = new Request ("GET" , getSecurityEndpoint () + "/user/" + user );;
691
689
Map <String , Object > response = entityAsMap (client ().performRequest (request ));
692
- @ SuppressWarnings ( "unchecked" ) Map <String , Object > userInfo = (Map <String , Object >) response .get (user );
690
+ Map <?, ? > userInfo = (Map <?, ? >) response .get (user );
693
691
assertEquals (user + "@example.com" , userInfo .get ("email" ));
694
692
assertNotNull (userInfo .get ("full_name" ));
695
693
assertNotNull (userInfo .get ("roles" ));
0 commit comments