-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Description
version: 2.8
broker.conf modify content : functionsWorkerEnabled=true
function use:
./pulsar-admin functions create --jar /Users/developer/Documents/personal/pulsar/func/pulsar-tester-api-0.0.1.jar --classname func.LogFunction --tenant public --namespace default --name log --inputs persistent://public/default/simple --output persistent://public/default/out
./pulsar-admin functions start --name log
pulsar- admin response:
`18:51:31.964 [AsyncHttpClient-7-1] WARN org.apache.pulsar.client.admin.internal.BaseResource - [http://localhost:8080/admin/v3/functions/public/default/log/start] Failed to perform http post request: javax.ws.rs.BadRequestException: HTTP 400 Bad Request
Operation not permitted
Reason: Operation not permitted
`
broker server log problem:
11:31:02.383 [function-timer-thread-91-1] ERROR org.apache.pulsar.functions.runtime.process.ProcessRuntime - Extracted Process death exception java.lang.RuntimeException: at org.apache.pulsar.functions.runtime.process.ProcessRuntime.tryExtractingDeathException(ProcessRuntime.java:402) ~[classes/:?] at org.apache.pulsar.functions.runtime.process.ProcessRuntime.isAlive(ProcessRuntime.java:389) ~[classes/:?] at org.apache.pulsar.functions.runtime.RuntimeSpawner.lambda$start$0(RuntimeSpawner.java:86) ~[classes/:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_251] at java.util.concurrent.FutureTask.runAndReset$$$capture(FutureTask.java:308) [?:1.8.0_251] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java) [?:1.8.0_251] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_251] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_251] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_251] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_251] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-common-4.1.68.Final.jar:4.1.68.Final] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_251] 11:31:02.389 [function-timer-thread-91-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/LogFunction-java.lang.RuntimeException: Function Container is dead with exception.. restarting