commit 3459657ebfb2855ba7a3265d8973d178d7bded59
author Boyang Jerry Peng <jerry.boyang.peng@gmail.com> Wed Sep 23 14:52:01 2020 -0700
committer GitHub <noreply@github.com> Wed Sep 23 14:52:01 2020 -0700
tree 4d43fe9c1e2e92c1b9da462e701f64d8b63c6993
parent 31c31ab28e89eb3a165f4c4556d05ec782369e91

Fix pulsar functions threaded integration tests (#8118)

Co-authored-by: Jerry Peng <jerryp@splunk.com>

tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java

diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
index 36175a6..db77ae6 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
@@ -417,7 +417,8 @@
                 .withEnv("PF_pulsarFunctionsCluster", clusterName)
                 .withEnv("PF_pulsarServiceUrl", serviceUrl)
                 .withEnv("PF_pulsarWebServiceUrl", httpServiceUrl)
-                .withEnv("PF_threadContainerFactory_threadGroupName", "pf-container-group")
+                .withEnv("PF_functionRuntimeFactoryClassName", "org.apache.pulsar.functions.runtime.thread.ThreadRuntimeFactory")
+                .withEnv("PF_functionRuntimeFactoryConfigs_threadGroupName", "pf-container-group")
                 // script
                 .withEnv("clusterName", clusterName)
                 .withEnv("zookeeperServers", ZKContainer.NAME)