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 configs = new HashMap<>(); configs.put(TaskConfig.CALLBACK_TIMEOUT_MS, "100"); - configs.put(PROCESS_JITTER, "200"); + configs.put(PROCESS_JITTER, "2000"); try { runTest(configs);