suztomo edited a comment on pull request #14768: URL: https://github.com/apache/beam/pull/14768#issuecomment-840576342
Trace log for failed `org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer` test ([jenkins link](https://ci-beam.apache.org/job/beam_PreCommit_Java_Commit/17698/testReport/junit/org.apache.beam.runners.fnexecution.logging/GrpcLoggingServiceTest/testMultipleClientsFailingIsHandledGracefullyByServer/)). ``` 04:01:34.891 [Time-limited test] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Started testMultipleClientsFailingIsHandledGracefullyByServer 04:01:34.894 [Time-limited test] DEBUG o.a.b.v.g.v.i.g.i.ServerImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusStatsAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImplBuilder.getTracerFactories(ServerImplBuilder.java:242) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImplBuilder.build(ServerImplBuilder.java:231) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractServerImplBuilder.build(AbstractServerImplBuilder.java:166) at org.apache.beam.runners.fnexecution.InProcessServerFactory.allocateAddressAndCreate(InProcessServerFactory.java:54) at org.apache.beam.runners.fnexecution.GrpcFnServer.allocatePortAndCreateFor(GrpcFnServer.java:47) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer(GrpcLoggingServiceTest.java:110) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288) at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.lang.Thread.run(Thread.java:748) 04:01:34.895 [Time-limited test] DEBUG o.a.b.v.g.v.i.g.i.ServerImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusTracingAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImplBuilder.getTracerFactories(ServerImplBuilder.java:274) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImplBuilder.build(ServerImplBuilder.java:231) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractServerImplBuilder.build(AbstractServerImplBuilder.java:166) at org.apache.beam.runners.fnexecution.InProcessServerFactory.allocateAddressAndCreate(InProcessServerFactory.java:54) at org.apache.beam.runners.fnexecution.GrpcFnServer.allocatePortAndCreateFor(GrpcFnServer.java:47) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer(GrpcLoggingServiceTest.java:110) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288) at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.lang.Thread.run(Thread.java:748) 04:01:34.930 [pool-123-thread-1] DEBUG o.a.b.v.g.v.i.g.i.ManagedChannelImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusStatsAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.getEffectiveInterceptors(ManagedChannelImplBuilder.java:632) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.lambda$testMultipleClientsFailingIsHandledGracefullyByServer$2(GrpcLoggingServiceTest.java:119) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.931 [pool-123-thread-1] DEBUG o.a.b.v.g.v.i.g.i.ManagedChannelImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusTracingAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.getEffectiveInterceptors(ManagedChannelImplBuilder.java:667) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.lambda$testMultipleClientsFailingIsHandledGracefullyByServer$2(GrpcLoggingServiceTest.java:119) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.946 [grpc-default-executor-5] INFO o.a.b.r.f.logging.GrpcLoggingService - Beam Fn Logging client connected. 04:01:34.947 [pool-123-thread-1] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Sending onError for client 1 04:01:34.948 [pool-123-thread-1] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Sent onError for client 1. Waiting for java.util.concurrent.CountDownLatch@23bbb82a[Count = 1] 04:01:34.948 [grpc-default-executor-3] WARN o.a.b.r.f.logging.GrpcLoggingService - Logging client failed unexpectedly. org.apache.beam.vendor.grpc.v1p37p0.io.grpc.StatusRuntimeException: CANCELLED: client cancelled at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.Status.asRuntimeException(Status.java:526) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:284) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:353) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:341) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:844) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.949 [grpc-default-executor-5] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Counting down the latch java.util.concurrent.CountDownLatch@23bbb82a[Count = 1] 04:01:34.949 [grpc-default-executor-5] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Counted down the latch java.util.concurrent.CountDownLatch@23bbb82a[Count = 0] 04:01:34.954 [pool-123-thread-2] DEBUG o.a.b.v.g.v.i.g.i.ManagedChannelImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusStatsAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.getEffectiveInterceptors(ManagedChannelImplBuilder.java:632) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.lambda$testMultipleClientsFailingIsHandledGracefullyByServer$2(GrpcLoggingServiceTest.java:119) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.955 [pool-123-thread-2] DEBUG o.a.b.v.g.v.i.g.i.ManagedChannelImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusTracingAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.getEffectiveInterceptors(ManagedChannelImplBuilder.java:667) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.lambda$testMultipleClientsFailingIsHandledGracefullyByServer$2(GrpcLoggingServiceTest.java:119) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.956 [pool-123-thread-2] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Sending onError for client 2 04:01:34.956 [pool-123-thread-2] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Sent onError for client 2. Waiting for java.util.concurrent.CountDownLatch@72902158[Count = 1] 04:01:34.956 [grpc-default-executor-1] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Counting down the latch java.util.concurrent.CountDownLatch@72902158[Count = 1] 04:01:34.956 [grpc-default-executor-1] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Counted down the latch java.util.concurrent.CountDownLatch@72902158[Count = 0] 04:01:34.958 [pool-123-thread-3] DEBUG o.a.b.v.g.v.i.g.i.ManagedChannelImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusStatsAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.getEffectiveInterceptors(ManagedChannelImplBuilder.java:632) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.lambda$testMultipleClientsFailingIsHandledGracefullyByServer$2(GrpcLoggingServiceTest.java:119) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.958 [grpc-default-executor-5] INFO o.a.b.r.f.logging.GrpcLoggingService - Beam Fn Logging client connected. 04:01:34.959 [grpc-default-executor-5] WARN o.a.b.r.f.logging.GrpcLoggingService - Logging client failed unexpectedly. org.apache.beam.vendor.grpc.v1p37p0.io.grpc.StatusRuntimeException: CANCELLED: client cancelled at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.Status.asRuntimeException(Status.java:526) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:284) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:353) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:341) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:844) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.959 [pool-123-thread-3] DEBUG o.a.b.v.g.v.i.g.i.ManagedChannelImplBuilder - Unable to apply census stats java.lang.ClassNotFoundException: org.apache.beam.vendor.grpc.v1p37p0.io.grpc.census.InternalCensusTracingAccessor at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.getEffectiveInterceptors(ManagedChannelImplBuilder.java:667) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261) at org.apache.beam.runners.fnexecution.logging.GrpcLoggingServiceTest.lambda$testMultipleClientsFailingIsHandledGracefullyByServer$2(GrpcLoggingServiceTest.java:119) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.960 [grpc-default-executor-5] INFO o.a.b.r.f.logging.GrpcLoggingService - Beam Fn Logging client connected. 04:01:34.961 [pool-123-thread-3] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Sending onError for client 3 04:01:34.961 [grpc-default-executor-5] WARN o.a.b.r.f.logging.GrpcLoggingService - Logging client failed unexpectedly. org.apache.beam.vendor.grpc.v1p37p0.io.grpc.StatusRuntimeException: CANCELLED: client cancelled at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.Status.asRuntimeException(Status.java:526) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:284) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:353) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:341) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:844) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at org.apache.beam.vendor.grpc.v1p37p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 04:01:34.961 [pool-123-thread-3] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Sent onError for client 3. Waiting for java.util.concurrent.CountDownLatch@3bef72ea[Count = 1] 04:01:39.895 [Time-limited test] INFO o.a.b.r.f.l.GrpcLoggingServiceTest - Finishing testMultipleClientsFailingIsHandledGracefullyByServer ``` The 2 of 3 `CountDownLatch`es (namely `CountDownLatch@23bbb82a` and `CountDownLatch@72902158`) were counted down correctly. For the last one `CountDownLatch@3bef72ea`, I can't tell why the grpc-default-executors stopped working after it showed `04:01:34.961 [grpc-default-executor-5] WARN o.a.b.r.f.logging.GrpcLoggingService - Logging client failed unexpectedly`. They were supposed to count down the "CountDownLatch@3bef72ea" by printing `Counting down the latch java.util.concurrent.CountDownLatch...`. -- 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]
