@@ -164,7 +164,6 @@ public void testSearch() throws Exception {
164164 assertAllSearchWorks (count );
165165 assertBasicAggregationWorks ();
166166 assertRealtimeGetWorks ();
167- assertUpgradeWorks ();
168167 assertStoredBinaryFields (count );
169168 }
170169
@@ -530,71 +529,6 @@ void assertRealtimeGetWorks() throws IOException {
530529 assertEquals (200 , response .getStatusLine ().getStatusCode ());
531530 }
532531
533- void assertUpgradeWorks () throws Exception {
534- if (runningAgainstOldCluster ) {
535- Map <String , Object > rsp = toMap (client ().performRequest ("GET" , "/_upgrade" ));
536- Map <?, ?> indexUpgradeStatus = (Map <?, ?>) XContentMapValues .extractValue ("indices." + index , rsp );
537- int totalBytes = (Integer ) indexUpgradeStatus .get ("size_in_bytes" );
538- assertThat (totalBytes , greaterThan (0 ));
539- int toUpgradeBytes = (Integer ) indexUpgradeStatus .get ("size_to_upgrade_in_bytes" );
540- assertEquals (0 , toUpgradeBytes );
541- } else {
542- // Pre upgrade checks:
543- Map <String , Object > rsp = toMap (client ().performRequest ("GET" , "/_upgrade" ));
544- Map <?, ?> indexUpgradeStatus = (Map <?, ?>) XContentMapValues .extractValue ("indices." + index , rsp );
545- int totalBytes = (Integer ) indexUpgradeStatus .get ("size_in_bytes" );
546- assertThat (totalBytes , greaterThan (0 ));
547- int toUpgradeBytes = (Integer ) indexUpgradeStatus .get ("size_to_upgrade_in_bytes" );
548- assertThat (toUpgradeBytes , greaterThan (0 ));
549-
550- Response r = client ().performRequest ("POST" , "/" + index + "/_flush" );
551- assertEquals (200 , r .getStatusLine ().getStatusCode ());
552-
553- // Upgrade segments:
554- r = client ().performRequest ("POST" , "/" + index + "/_upgrade" );
555- assertEquals (200 , r .getStatusLine ().getStatusCode ());
556- rsp = toMap (r );
557- logger .info ("upgrade api response: {}" , rsp );
558- Map <?, ?> versions = (Map <?, ?>) XContentMapValues .extractValue ("upgraded_indices." + index , rsp );
559- assertNotNull (versions );
560- Version upgradeVersion = Version .fromString ((String ) versions .get ("upgrade_version" ));
561- assertEquals (Version .CURRENT , upgradeVersion );
562- org .apache .lucene .util .Version luceneVersion =
563- org .apache .lucene .util .Version .parse ((String ) versions .get ("oldest_lucene_segment_version" ));
564- assertEquals (Version .CURRENT .luceneVersion , luceneVersion );
565-
566- r = client ().performRequest ("POST" , "/" + index + "/_refresh" );
567- assertEquals (200 , r .getStatusLine ().getStatusCode ());
568-
569- // Post upgrade checks:
570- rsp = toMap (client ().performRequest ("GET" , "/_upgrade" ));
571- logger .info ("upgrade status api response: {}" , rsp );
572- indexUpgradeStatus = (Map <?, ?>) XContentMapValues .extractValue ("indices." + index , rsp );
573- assertNotNull (indexUpgradeStatus );
574- totalBytes = (Integer ) indexUpgradeStatus .get ("size_in_bytes" );
575- assertThat (totalBytes , greaterThan (0 ));
576- toUpgradeBytes = (Integer ) indexUpgradeStatus .get ("size_to_upgrade_in_bytes" );
577- assertEquals (0 , toUpgradeBytes );
578-
579- rsp = toMap (client ().performRequest ("GET" , "/" + index + "/_segments" ));
580- Map <?, ?> shards = (Map <?, ?>) XContentMapValues .extractValue ("indices." + index + ".shards" , rsp );
581- for (Object shard : shards .values ()) {
582- List <?> shardSegments = (List <?>) shard ;
583- for (Object shardSegment : shardSegments ) {
584- Map <?, ?> shardSegmentRsp = (Map <?, ?>) shardSegment ;
585- Map <?, ?> segments = (Map <?, ?>) shardSegmentRsp .get ("segments" );
586- for (Object segment : segments .values ()) {
587- Map <?, ?> segmentRsp = (Map <?, ?>) segment ;
588- luceneVersion = org .apache .lucene .util .Version .parse ((String ) segmentRsp .get ("version" ));
589- assertEquals ("Un-upgraded segment " + segment , Version .CURRENT .luceneVersion .major , luceneVersion .major );
590- assertEquals ("Un-upgraded segment " + segment , Version .CURRENT .luceneVersion .minor , luceneVersion .minor );
591- assertEquals ("Un-upgraded segment " + segment , Version .CURRENT .luceneVersion .bugfix , luceneVersion .bugfix );
592- }
593- }
594- }
595- }
596- }
597-
598532 void assertStoredBinaryFields (int count ) throws Exception {
599533 String requestBody = "{ \" query\" : { \" match_all\" : {} }, \" size\" : 100, \" stored_fields\" : \" binary\" }" ;
600534 Map <String , Object > rsp = toMap (client ().performRequest ("GET" , "/" + index + "/_search" ,
0 commit comments