KannarFr commented on issue #5519: Create producer issues using function worker as separate node URL: https://github.com/apache/pulsar/issues/5519#issuecomment-548778847 In separate function worker, the log is: ``` Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: 10:46:08.603 [pulsar-client-io-16-1] WARN org.apache.pulsar.client.impl.PulsarClientImpl - [persistent://clevercloud/functions/assignments] Failed to get partitioned topic metadata: org.apache.pulsar.client.api.PulsarClientException$LookupExcepti on: java.util.concurrent.ExecutionException: org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: 10:46:08.603 [pulsar-client-io-16-1] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x307f84dd, L:/10.2.1.4:54488 ! R:c1-pulsar-clevercloud-customers.services.clever-cloud.com/185.42.117.147:2001] Disconnected Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: 10:46:08.603 [main] ERROR org.apache.pulsar.functions.worker.SchedulerManager - Exception while at creating producer to topic persistent://clevercloud/functions/assignments Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: java.util.concurrent.ExecutionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: java.util.concurrent.ExecutionException: org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_192] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) ~[?:1.8.0_192] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.worker.SchedulerManager.lambda$createProducer$0(SchedulerManager.java:109) ~[org.apache.pulsar-pulsar-functions-worker-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.utils.Actions.runAction(Actions.java:110) [org.apache.pulsar-pulsar-functions-utils-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.utils.Actions.run(Actions.java:92) [org.apache.pulsar-pulsar-functions-utils-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.worker.SchedulerManager.createProducer(SchedulerManager.java:125) [org.apache.pulsar-pulsar-functions-worker-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.worker.SchedulerManager.<init>(SchedulerManager.java:91) [org.apache.pulsar-pulsar-functions-worker-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:152) [org.apache.pulsar-pulsar-functions-worker-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.worker.Worker.start(Worker.java:68) [org.apache.pulsar-pulsar-functions-worker-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: java.util.concurrent.ExecutionException: org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:895) ~[org.apache.pulsar-pulsar-client-original-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.client.impl.ClientCnx.handlePartitionResponse(ClientCnx.java:497) ~[org.apache.pulsar-pulsar-client-original-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:103) ~[org.apache.pulsar-pulsar-common-2.4.0.jar:2.4.0] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Oct 31 10:46:08 clevercloud-pulsar-c1-n7 pulsar-functions-worker[5646]: at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_192] ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
