Bump up timeout in testTopicAnomalyFinder (linkedin#1730)

barthy1 · Nov 15, 2021 · 1290039 · 1290039
1 parent 74105f3
commit 1290039
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...rc/integrationTest/java/com/linkedin/kafka/cruisecontrol/TopicAnomalyIntegrationTest.java b/...rc/integrationTest/java/com/linkedin/kafka/cruisecontrol/TopicAnomalyIntegrationTest.java
@@ -80,7 +80,7 @@ protected Map<String, Object> withConfigs() {
 
   @Test
   public void testTopicAnomalyFinder() {
-    KafkaCruiseControlIntegrationTestUtils.createTopic(broker(0).plaintextAddr(), 
+    KafkaCruiseControlIntegrationTestUtils.createTopic(broker(0).plaintextAddr(),
         new NewTopic(TOPIC0, PARTITION_COUNT, (short) 2));
 
     waitForMetadataPropogates();
@@ -101,7 +101,7 @@ private void waitUntilNewReplicasAppearForTheTopic() {
       List<List<Integer>> partitionReplicas = JsonPath.parse(replicasArray, _gsonJsonConfig)
           .read("$.*", new TypeRef<>() { });
       return partitionReplicas.stream().allMatch(i -> i.size() == EXPECTED_REPLICA_COUNT);
-    }, Duration.ofSeconds(200), Duration.ofSeconds(15), new AssertionError("Replica count not match"));
+    }, Duration.ofSeconds(800), Duration.ofSeconds(15), new AssertionError("Replica count not match"));
   }
 
   private void waitForMetadataPropogates() {