From 6413ff51e777ce35ff3807dc5ba75ad607a2f465 Mon Sep 17 00:00:00 2001
From: Zhifeng Chen <chenz@uber.com>
Date: Tue, 12 Mar 2024 19:28:55 -0700
Subject: [PATCH] fix flaky test testSubmitMessageWithCommitResponse

---
 .../kafka/consumerproxy/worker/processor/ProcessorImplTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java b/uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java
index 08243a3..67e883e 100644
--- a/uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java
+++ b/uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java
@@ -246,7 +246,7 @@ public void testSubmitMessageWithSameClusterShouldNotBeFiltered() throws Excepti
         dispatcherMessageArgumentCaptor.getValue().getItem().getGrpcMessage().getDispatchAttempt());
   }
 
-  @Test(timeout = 5000)
+  @Test(timeout = 10000)
   public void testSubmitMessageWithCommitResponse() throws Exception {
     processor.start();
     CompletableFuture<DispatcherResponse> dispatcherFuture = new CompletableFuture<>();