This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 2d76839dc28ddbfc2dd9f052551b8d063128ebdc Author: Cong Zhao <[email protected]> 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 5592e6975cd..7029dc222db 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 @@ -27,7 +27,6 @@ import static org.testng.Assert.assertFalse; import static org.testng.Assert.assertNotEquals; import static org.testng.Assert.assertTrue; import static org.testng.Assert.fail; - import com.google.common.collect.Lists; import com.google.common.collect.Sets; import java.io.File; @@ -47,7 +46,6 @@ import java.util.Objects; import java.util.Optional; import java.util.Set; import java.util.concurrent.TimeUnit; - import lombok.Cleanup; import org.apache.pulsar.broker.PulsarService; import org.apache.pulsar.broker.ServiceConfiguration; @@ -427,6 +425,7 @@ public class PulsarFunctionLocalRunTest { functionConfig.setJar(jarFilePathUrl); functionConfig.setParallelism(parallelism); + functionConfig.setRetainOrdering(true); int metricsPort = FunctionCommon.findAvailablePort(); @Cleanup LocalRunner localRunner = LocalRunner.builder()
