Fix pulsar functions threaded integration tests
@@ -417,7 +417,8 @@ public class PulsarCluster {
.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)
