diff --git a/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/CcrRepositoryIT.java b/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/CcrRepositoryIT.java
index f22857939e0d1..fdf2de6d6775f 100644
--- a/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/CcrRepositoryIT.java
+++ b/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/CcrRepositoryIT.java
@@ -55,7 +55,9 @@
 import static org.elasticsearch.snapshots.RestoreService.restoreInProgress;
 import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked;
 import static org.hamcrest.Matchers.equalTo;
+import static org.hamcrest.Matchers.greaterThan;
 import static org.hamcrest.Matchers.instanceOf;
+import static org.hamcrest.Matchers.lessThan;
 
 // TODO: Fold this integration test into a more expansive integration test as more bootstrap from remote work
 // TODO: is completed.
@@ -367,8 +369,9 @@ public void testIndividualActionsTimeout() throws Exception {
         // be marked as failed. Either one is a success for the purpose of this test.
         try {
             RestoreInfo restoreInfo = future.actionGet();
-            assertEquals(0, restoreInfo.successfulShards());
-            assertEquals(numberOfPrimaryShards, restoreInfo.failedShards());
+            assertThat(restoreInfo.failedShards(), greaterThan(0));
+            assertThat(restoreInfo.successfulShards(), lessThan(restoreInfo.totalShards()));
+            assertEquals(numberOfPrimaryShards, restoreInfo.totalShards());
         } catch (Exception e) {
             assertThat(ExceptionsHelper.unwrapCause(e), instanceOf(ElasticsearchTimeoutException.class));
         }