[samza] branch master updated: [Tests] Add longer delay time to mitigate flaky test in TestAsyncFlatMap (#1561)

[cameronlee]

This is an automated email from the ASF dual-hosted git repository.

cameronlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new dc687db  [Tests] Add longer delay time to mitigate flaky test in 
TestAsyncFlatMap (#1561)
dc687db is described below

commit dc687dbb8e37061917c553e19ce61eab89694a0e
Author: Cameron Lee <ca...@linkedin.com>
AuthorDate: Wed Nov 17 16:43:41 2021 -0800

    [Tests] Add longer delay time to mitigate flaky test in TestAsyncFlatMap 
(#1561)
---
 .../src/test/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 462841c..6215a51 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 class TestAsyncFlatMap {
   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);