From 812ed049a2f39a68ea41c14e36a53beed240296a Mon Sep 17 00:00:00 2001
From: Cameron Lee <calee@linkedin.com>
Date: Wed, 17 Nov 2021 15:30:14 -0800
Subject: [PATCH] [Tests] Add longer delay time to mitigate flaky test in
 TestAsyncFlatMap

---
 .../java/org/apache/samza/test/operator/TestAsyncFlatMap.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/samza-test/src/test/java/org/apache/samza/test/operator/TestAsyncFlatMap.java b/samza-test/src/test/java/org/apache/samza/test/operator/TestAsyncFlatMap.java
index 462841c106..6215a51897 100644
--- a/samza-test/src/test/java/org/apache/samza/test/operator/TestAsyncFlatMap.java
+++ b/samza-test/src/test/java/org/apache/samza/test/operator/TestAsyncFlatMap.java
@@ -82,7 +82,7 @@ public void testProcessingFutureCompletesSuccessfully() {
   public void testProcessingFutureCompletesAfterTaskTimeout() {
     Map<String, String> configs = new HashMap<>();
     configs.put(TaskConfig.CALLBACK_TIMEOUT_MS, "100");
-    configs.put(PROCESS_JITTER, "200");
+    configs.put(PROCESS_JITTER, "2000");
 
     try {
       runTest(configs);