[pulsar] branch branch-2.9 updated: fix Flaky-test: PulsarFunctionLocalRunTest.testE2EPulsarFunctionLocalRunMultipleInstance (#16872)

[bogong]

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

bogong pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.9 by this push:
     new 67ee852fbc6 fix Flaky-test: 
PulsarFunctionLocalRunTest.testE2EPulsarFunctionLocalRunMultipleInstance 
(#16872)
67ee852fbc6 is described below

commit 67ee852fbc604f6b0ce2fd0d582a3e220110e22e
Author: Cong Zhao <zhaoc...@apache.org>
AuthorDate: Wed Aug 3 11:06:51 2022 +0800

    fix Flaky-test: 
PulsarFunctionLocalRunTest.testE2EPulsarFunctionLocalRunMultipleInstance 
(#16872)
    
    (cherry picked from commit e8fd71efd86fbd2ed28e8e7205daa49826ef0afa)
---
 .../org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
index c48de5257b3..e5d9ecd9005 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
@@ -28,7 +28,6 @@ import static org.testng.Assert.assertNotEquals;
 import static org.testng.Assert.assertNotNull;
 import static org.testng.Assert.assertTrue;
 import static org.testng.Assert.fail;
-
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
@@ -49,7 +48,6 @@ import java.util.Objects;
 import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
-
 import lombok.Builder;
 import lombok.Cleanup;
 import org.apache.pulsar.broker.PulsarService;
@@ -429,6 +427,7 @@ public class PulsarFunctionLocalRunTest {
 
         functionConfig.setJar(jarFilePathUrl);
         functionConfig.setParallelism(parallelism);
+        functionConfig.setRetainOrdering(true);
         int metricsPort = FunctionCommon.findAvailablePort();
         @Cleanup
         LocalRunner localRunner = LocalRunner.builder()