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