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,