@@ -363,9 +363,9 @@ public void testCircuitBreakingException() throws IOException {
363
363
}
364
364
365
365
public void testTooManyBucketsException () throws IOException {
366
+ Version version = VersionUtils .randomVersionBetween (random (), Version .V_6_2_0 , Version .CURRENT );
366
367
MultiBucketConsumerService .TooManyBucketsException ex =
367
- serialize (new MultiBucketConsumerService .TooManyBucketsException ("Too many buckets" , 100 ),
368
- randomFrom (Version .V_7_0_0 ));
368
+ serialize (new MultiBucketConsumerService .TooManyBucketsException ("Too many buckets" , 100 ), version );
369
369
assertEquals ("Too many buckets" , ex .getMessage ());
370
370
assertEquals (100 , ex .getMaxBuckets ());
371
371
}
@@ -880,6 +880,13 @@ public void testShardLockObtainFailedException() throws IOException {
880
880
assertEquals (orig .getShardId (), ex .getShardId ());
881
881
}
882
882
883
+ public void testSnapshotInProgressException () throws IOException {
884
+ SnapshotInProgressException orig = new SnapshotInProgressException ("boom" );
885
+ Version version = VersionUtils .randomVersionBetween (random (), Version .V_6_7_0 , Version .CURRENT );
886
+ SnapshotInProgressException ex = serialize (orig , version );
887
+ assertEquals (orig .getMessage (), ex .getMessage ());
888
+ }
889
+
883
890
private static class UnknownException extends Exception {
884
891
UnknownException (final String message , final Exception cause ) {
885
892
super (message , cause );
0 commit comments