Hello,
After upgrading Zeebe from 0.x to 1.x, I had to make a change in the Zeebe client build,
Earlier,
ZeebeClient.newClientBuilder()
.brokerContactPoint(zeebeBrokerContactpoint)
.usePlaintext()
.numJobWorkerExecutionThreads(zeebeClientMaxThreads)
.build();
After Zeebe 1.x.
return ZeebeClient.newClientBuilder()
.gatewayAddress(zeebeBrokerContactpoint)
.usePlaintext()
.numJobWorkerExecutionThreads(zeebeClientMaxThreads)
.build();
now the logs are full of warning stating:
03:51:58.627 WARN [ grpc-default-executor-486] i.c.zeebe.client.job.poller : Failed to activated jobs for worker notify-ams-failure and job β
β io.grpc.StatusRuntimeException: INTERNAL: Panic! This is a bug! β
β at io.grpc.Status.asRuntimeException(Status.java:535) β
β at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:478) β
β at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:553) β
β at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:68) β
β at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:739) β
β at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:718) β
β at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) β
β at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) β
β at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) β
β at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) β
β at java.base/java.lang.Thread.run(Thread.java:830) β
β Caused by: java.lang.NoSuchMethodError: 'void io.netty.buffer.PooledByteBufAllocator.<init>(boolean, int, int, int, int, int, int, boolean)' β
β at io.grpc.netty.Utils.createByteBufAllocator(Utils.java:172) β
β at io.grpc.netty.Utils.access$000(Utils.java:71) β
β at io.grpc.netty.Utils$ByteBufAllocatorPreferDirectHolder.<clinit>(Utils.java:93) β
β at io.grpc.netty.Utils.getByteBufAllocator(Utils.java:140) β
β at io.grpc.netty.NettyClientTransport.start(NettyClientTransport.java:231) β
β at io.grpc.internal.ForwardingConnectionClientTransport.start(ForwardingConnectionClientTransport.java:33) β
β at io.grpc.internal.ForwardingConnectionClientTransport.start(ForwardingConnectionClientTransport.java:33) β
β at io.grpc.internal.InternalSubchannel.startNewTransport(InternalSubchannel.java:258) β
β at io.grpc.internal.InternalSubchannel.access$400(InternalSubchannel.java:65) β
β at io.grpc.internal.InternalSubchannel$2.run(InternalSubchannel.java:200) β
β at io.grpc.SynchronizationContext.drain(SynchronizationContext.java:95)
Any insight on what could be going wrong?
Thanks,