Advertisement
Guest User

Untitled

a guest
Mar 13th, 2023
15
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 15.69 KB | None | 0 0
  1. ```
  2. ❯ ./mill show worker.assembly
  3. [1/1] show
  4. [1/1] show > [37/76] worker.sources
  5. "ref:7995bc66:/Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar"
  6. ❯ file /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
  7. /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar: data
  8. ❯ ls -ltr /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
  9. -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
  10. ❯ java -jar /Users/cdepaula/repos/scala-playground/zio-temporal-hello/out/worker/assembly.dest/out.jar
  11. timestamp=2023-03-13T09:27:42.575424-03:00 level=INFO thread=zio-fiber-7 message="Started sample-worker listening to queue echo-queue"
  12. 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"
  13. 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
  14. at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
  15. at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
  16. at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
  17. at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252)
  18. at io.temporal.serviceclient.ChannelManager.healthCheck(ChannelManager.java:302)
  19. at io.temporal.serviceclient.ChannelManager.lambda$connect$2(ChannelManager.java:277)
  20. at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:60)
  21. at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:66)
  22. at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60)
  23. at io.temporal.serviceclient.ChannelManager.connect(ChannelManager.java:277)
  24. at io.temporal.serviceclient.WorkflowServiceStubsImpl.connect(WorkflowServiceStubsImpl.java:159)
  25. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  26. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
  27. at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  28. at java.base/java.lang.reflect.Method.invoke(Method.java:568)
  29. at io.temporal.internal.WorkflowThreadMarker.lambda$protectFromWorkflowThread$1(WorkflowThreadMarker.java:83)
  30. at jdk.proxy2/jdk.proxy2.$Proxy2.connect(Unknown Source)
  31. at io.temporal.worker.WorkerFactory.start(WorkerFactory.java:207)
  32. at zio.temporal.worker.ZWorkerFactory.start$$anonfun$1$$anonfun$1(ZWorkerFactory.scala:33)
  33. at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
  34. at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
  35. at zio.UnsafeVersionSpecific.implicitFunctionIsFunction$$anonfun$1(UnsafeVersionSpecific.scala:27)
  36. at zio.Unsafe$.unsafe(Unsafe.scala:37)
  37. at zio.ZIOCompanionVersionSpecific.succeed$$anonfun$1(ZIOCompanionVersionSpecific.scala:157)
  38. at zio.temporal.worker.ZWorkerFactory.start.macro(ZWorkerFactory.scala:33)
  39. at zio.temporal.worker.ZWorkerFactory.use.macro(ZWorkerFactory.scala:28)
  40. at <empty>.Main.run.program(Main.scala:42)
  41. at <empty>.Main.run(Main.scala:44)
  42. Suppressed: java.nio.channels.UnsupportedAddressTypeException: null
  43. at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
  44. at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
  45. at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
  46. at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
  47. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
  48. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
  49. at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
  50. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
  51. at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:315)
  52. at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
  53. at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
  54. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
  55. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
  56. at io.grpc.netty.shaded.io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
  57. at io.grpc.netty.shaded.io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
  58. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
  59. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
  60. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
  61. at io.grpc.netty.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
  62. at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
  63. at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
  64. at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
  65. at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  66. at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  67. at java.base/java.lang.Thread.run(Thread.java:833)
  68. 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
  69. at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
  70. at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
  71. at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
  72. at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252)
  73. at io.temporal.serviceclient.ChannelManager.healthCheck(ChannelManager.java:302)
  74. at io.temporal.serviceclient.ChannelManager.lambda$connect$2(ChannelManager.java:277)
  75. at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:60)
  76. at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:66)
  77. at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60)
  78. at io.temporal.serviceclient.ChannelManager.connect(ChannelManager.java:277)
  79. at io.temporal.serviceclient.WorkflowServiceStubsImpl.connect(WorkflowServiceStubsImpl.java:159)
  80. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  81. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
  82. at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  83. at java.base/java.lang.reflect.Method.invoke(Method.java:568)
  84. at io.temporal.internal.WorkflowThreadMarker.lambda$protectFromWorkflowThread$1(WorkflowThreadMarker.java:83)
  85. at jdk.proxy2/jdk.proxy2.$Proxy2.connect(Unknown Source)
  86. at io.temporal.worker.WorkerFactory.start(WorkerFactory.java:207)
  87. at zio.temporal.worker.ZWorkerFactory.start$$anonfun$1$$anonfun$1(ZWorkerFactory.scala:33)
  88. at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
  89. at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
  90. at zio.UnsafeVersionSpecific.implicitFunctionIsFunction$$anonfun$1(UnsafeVersionSpecific.scala:27)
  91. at zio.Unsafe$.unsafe(Unsafe.scala:37)
  92. at zio.ZIOCompanionVersionSpecific.succeed$$anonfun$1(ZIOCompanionVersionSpecific.scala:157)
  93. at zio.temporal.worker.ZWorkerFactory.start.macro(ZWorkerFactory.scala:33)
  94. at zio.temporal.worker.ZWorkerFactory.use.macro(ZWorkerFactory.scala:28)
  95. at <empty>.Main.run.program(Main.scala:42)
  96. at <empty>.Main.run(Main.scala:44)
  97. Suppressed: java.nio.channels.UnsupportedAddressTypeException: null
  98. at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
  99. at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
  100. at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
  101. at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
  102. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
  103. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
  104. at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
  105. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
  106. at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:315)
  107. at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
  108. at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
  109. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
  110. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
  111. at io.grpc.netty.shaded.io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
  112. at io.grpc.netty.shaded.io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
  113. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
  114. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
  115. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
  116. at io.grpc.netty.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
  117. at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
  118. at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
  119. at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
  120. at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  121. at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  122. at java.base/java.lang.Thread.run(Thread.java:833)
  123. 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
  124. at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
  125. at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
  126. at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
  127. at io.grpc.health.v1.HealthGrpc$HealthBlockingStub.check(HealthGrpc.java:252)
  128. at io.temporal.serviceclient.ChannelManager.healthCheck(ChannelManager.java:302)
  129. at io.temporal.serviceclient.ChannelManager.lambda$connect$2(ChannelManager.java:277)
  130. at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:60)
  131. at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:66)
  132. at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60)
  133. at io.temporal.serviceclient.ChannelManager.connect(ChannelManager.java:277)
  134. at io.temporal.serviceclient.WorkflowServiceStubsImpl.connect(WorkflowServiceStubsImpl.java:159)
  135. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  136. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
  137. at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  138. at java.base/java.lang.reflect.Method.invoke(Method.java:568)
  139. at io.temporal.internal.WorkflowThreadMarker.lambda$protectFromWorkflowThread$1(WorkflowThreadMarker.java:83)
  140. at jdk.proxy2/jdk.proxy2.$Proxy2.connect(Unknown Source)
  141. at io.temporal.worker.WorkerFactory.start(WorkerFactory.java:207)
  142. at zio.temporal.worker.ZWorkerFactory.start$$anonfun$1$$anonfun$1(ZWorkerFactory.scala:33)
  143. at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
  144. at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
  145. at zio.UnsafeVersionSpecific.implicitFunctionIsFunction$$anonfun$1(UnsafeVersionSpecific.scala:27)
  146. at zio.Unsafe$.unsafe(Unsafe.scala:37)
  147. at zio.ZIOCompanionVersionSpecific.succeed$$anonfun$1(ZIOCompanionVersionSpecific.scala:157)
  148. at zio.temporal.worker.ZWorkerFactory.start.macro(ZWorkerFactory.scala:33)
  149. at zio.temporal.worker.ZWorkerFactory.use.macro(ZWorkerFactory.scala:28)
  150. at <empty>.Main.run.program(Main.scala:42)
  151. at <empty>.Main.run(Main.scala:44)
  152. Suppressed: java.nio.channels.UnsupportedAddressTypeException: null
  153. at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
  154. at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
  155. at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
  156. at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
  157. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
  158. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
  159. at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
  160. at io.grpc.netty.shaded.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
  161. at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:315)
  162. at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
  163. at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
  164. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
  165. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
  166. at io.grpc.netty.shaded.io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
  167. at io.grpc.netty.shaded.io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
  168. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
  169. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
  170. at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
  171. at io.grpc.netty.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
  172. at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
  173. at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
  174. at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
  175. at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  176. at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  177. at java.base/java.lang.Thread.run(Thread.java:833)
  178. ```
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement