Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ```
- ❯ ./mill show worker.assembly
- [1/1] show
- [1/1] show > [37/76] worker.sources
- "ref:7995bc66:/Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar"
- ❯ file /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
- /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar: data
- ❯ ls -ltr /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
- -rwxr-xr-x 1 cdepaula staff 60932182 Mar 12 11:03 /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
- ❯ java -jar /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
- timestamp=2023-03-13T09:27:42.575424-03:00 level=INFO thread=zio-fiber-7 message="Started sample-worker listening to queue echo-queue"
- timestamp=2023-03-13T09:27:42.637583-03:00 level=INFO thread=zio-fiber-6 message="HTTP Metrics Server started at http://localhost:8082/metrics"
- timestamp=2023-03-13T09:27:55.309601-03:00 level=DEBUG thread=zio-fiber-6 message="Fiber zio-fiber-6 did not handle an error" cause=Exception in thread "zio-fiber-6" io.grpc.StatusRuntimeException: UNKNOWN
- at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
- at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
- at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
- at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252)
- at io.temporal.serviceclient.ChannelManager.healthCheck(ChannelManager.java:302)
- at io.temporal.serviceclient.ChannelManager.lambda$connect$2(ChannelManager.java:277)
- at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:60)
- at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:66)
- at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60)
- at io.temporal.serviceclient.ChannelManager.connect(ChannelManager.java:277)
- at io.temporal.serviceclient.WorkflowServiceStubsImpl.connect(WorkflowServiceStubsImpl.java:159)
- at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
- at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
- at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- at java.base/java.lang.reflect.Method.invoke(Method.java:568)
- at io.temporal.internal.WorkflowThreadMarker.lambda$protectFromWorkflowThread$1(WorkflowThreadMarker.java:83)
- at jdk.proxy2/jdk.proxy2.$Proxy2.connect(Unknown Source)
- at io.temporal.worker.WorkerFactory.start(WorkerFactory.java:207)
- at zio.temporal.worker.ZWorkerFactory.start$$anonfun$1$$anonfun$1(ZWorkerFactory.scala:33)
- at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
- at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
- at zio.UnsafeVersionSpecific.implicitFunctionIsFunction$$anonfun$1(UnsafeVersionSpecific.scala:27)
- at zio.Unsafe$.unsafe(Unsafe.scala:37)
- at zio.ZIOCompanionVersionSpecific.succeed$$anonfun$1(ZIOCompanionVersionSpecific.scala:157)
- at zio.temporal.worker.ZWorkerFactory.start.macro(ZWorkerFactory.scala:33)
- at zio.temporal.worker.ZWorkerFactory.use.macro(ZWorkerFactory.scala:28)
- at <empty>.Main.run.program(Main.scala:42)
- at <empty>.Main.run(Main.scala:44)
- Suppressed: java.nio.channels.UnsupportedAddressTypeException: null
- at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
- at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
- at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
- at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
- at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
- at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:315)
- at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
- at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
- at io.grpc.netty.shaded.io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
- at io.grpc.netty.shaded.io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
- at io.grpc.netty.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
- at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
- at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
- at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
- at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- at java.base/java.lang.Thread.run(Thread.java:833)
- timestamp=2023-03-13T09:27:55.318544-03:00 level=DEBUG thread=zio-fiber-5 message="Fiber zio-fiber-5 did not handle an error" cause=Exception in thread "zio-fiber-6" io.grpc.StatusRuntimeException: UNKNOWN
- at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
- at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
- at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
- at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252)
- at io.temporal.serviceclient.ChannelManager.healthCheck(ChannelManager.java:302)
- at io.temporal.serviceclient.ChannelManager.lambda$connect$2(ChannelManager.java:277)
- at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:60)
- at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:66)
- at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60)
- at io.temporal.serviceclient.ChannelManager.connect(ChannelManager.java:277)
- at io.temporal.serviceclient.WorkflowServiceStubsImpl.connect(WorkflowServiceStubsImpl.java:159)
- at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
- at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
- at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- at java.base/java.lang.reflect.Method.invoke(Method.java:568)
- at io.temporal.internal.WorkflowThreadMarker.lambda$protectFromWorkflowThread$1(WorkflowThreadMarker.java:83)
- at jdk.proxy2/jdk.proxy2.$Proxy2.connect(Unknown Source)
- at io.temporal.worker.WorkerFactory.start(WorkerFactory.java:207)
- at zio.temporal.worker.ZWorkerFactory.start$$anonfun$1$$anonfun$1(ZWorkerFactory.scala:33)
- at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
- at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
- at zio.UnsafeVersionSpecific.implicitFunctionIsFunction$$anonfun$1(UnsafeVersionSpecific.scala:27)
- at zio.Unsafe$.unsafe(Unsafe.scala:37)
- at zio.ZIOCompanionVersionSpecific.succeed$$anonfun$1(ZIOCompanionVersionSpecific.scala:157)
- at zio.temporal.worker.ZWorkerFactory.start.macro(ZWorkerFactory.scala:33)
- at zio.temporal.worker.ZWorkerFactory.use.macro(ZWorkerFactory.scala:28)
- at <empty>.Main.run.program(Main.scala:42)
- at <empty>.Main.run(Main.scala:44)
- Suppressed: java.nio.channels.UnsupportedAddressTypeException: null
- at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
- at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
- at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
- at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
- at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
- at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:315)
- at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
- at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
- at io.grpc.netty.shaded.io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
- at io.grpc.netty.shaded.io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
- at io.grpc.netty.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
- at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
- at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
- at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
- at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- at java.base/java.lang.Thread.run(Thread.java:833)
- timestamp=2023-03-13T09:27:55.321804-03:00 level=ERROR thread=zio-fiber-0 message="" cause=Exception in thread "zio-fiber-6" io.grpc.StatusRuntimeException: UNKNOWN
- at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
- at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
- at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
- at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252)
- at io.temporal.serviceclient.ChannelManager.healthCheck(ChannelManager.java:302)
- at io.temporal.serviceclient.ChannelManager.lambda$connect$2(ChannelManager.java:277)
- at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:60)
- at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:66)
- at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60)
- at io.temporal.serviceclient.ChannelManager.connect(ChannelManager.java:277)
- at io.temporal.serviceclient.WorkflowServiceStubsImpl.connect(WorkflowServiceStubsImpl.java:159)
- at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
- at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
- at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- at java.base/java.lang.reflect.Method.invoke(Method.java:568)
- at io.temporal.internal.WorkflowThreadMarker.lambda$protectFromWorkflowThread$1(WorkflowThreadMarker.java:83)
- at jdk.proxy2/jdk.proxy2.$Proxy2.connect(Unknown Source)
- at io.temporal.worker.WorkerFactory.start(WorkerFactory.java:207)
- at zio.temporal.worker.ZWorkerFactory.start$$anonfun$1$$anonfun$1(ZWorkerFactory.scala:33)
- at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
- at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
- at zio.UnsafeVersionSpecific.implicitFunctionIsFunction$$anonfun$1(UnsafeVersionSpecific.scala:27)
- at zio.Unsafe$.unsafe(Unsafe.scala:37)
- at zio.ZIOCompanionVersionSpecific.succeed$$anonfun$1(ZIOCompanionVersionSpecific.scala:157)
- at zio.temporal.worker.ZWorkerFactory.start.macro(ZWorkerFactory.scala:33)
- at zio.temporal.worker.ZWorkerFactory.use.macro(ZWorkerFactory.scala:28)
- at <empty>.Main.run.program(Main.scala:42)
- at <empty>.Main.run(Main.scala:44)
- Suppressed: java.nio.channels.UnsupportedAddressTypeException: null
- at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
- at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
- at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
- at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
- at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
- at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
- at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:315)
- at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
- at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
- at io.grpc.netty.shaded.io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
- at io.grpc.netty.shaded.io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
- at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
- at io.grpc.netty.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
- at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
- at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
- at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
- at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
- at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
- at java.base/java.lang.Thread.run(Thread.java:833)
- ```
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement