diff --git a/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/CcrIntegTestCase.java b/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/CcrIntegTestCase.java index 725d4501c9a8b..dcbfff524ea14 100644 --- a/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/CcrIntegTestCase.java +++ b/x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/CcrIntegTestCase.java @@ -187,7 +187,7 @@ public final void startClusters() throws Exception { assertBusy(() -> { ClusterService clusterService = leaderCluster.getInstance(ClusterService.class); assertNotNull(clusterService.state().metadata().custom(LicensesMetadata.TYPE)); - }); + }, 60, TimeUnit.SECONDS); String address = leaderCluster.getDataNodeInstance(TransportService.class).boundAddress().publishAddress().toString(); InternalTestCluster followerCluster = new InternalTestCluster( @@ -211,7 +211,7 @@ public final void startClusters() throws Exception { assertBusy(() -> { ClusterService clusterService = followerCluster.getInstance(ClusterService.class); assertNotNull(clusterService.state().metadata().custom(LicensesMetadata.TYPE)); - }); + }, 60, TimeUnit.SECONDS); setupMasterNodeRequestsValidatorOnFollowerCluster(); }