Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Example worker error:
*~*~*~ Channel ManagedChannelImpl{logId=7, target=localhost:12374} was not shutdown properly!!! ~*~*~* Make sure to call shutdown()/shutdownNow() and wait until awaitTermination() returns true.
exception: "java.lang.RuntimeException: ManagedChannel allocation site
at org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:94)
at org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:52)
at org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:43)
at org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:524)
at org.apache.beam.sdk.fn.channel.ManagedChannelFactory$InterceptedManagedChannelFactory.forDescriptor(ManagedChannelFactory.java:107)
at org.apache.beam.fn.harness.status.BeamFnStatusClient.<init>(BeamFnStatusClient.java:57)
at org.apache.beam.fn.harness.FnHarness.main(FnHarness.java:279)
at org.apache.beam.fn.harness.FnHarness.main(FnHarness.java:183)
at org.apache.beam.fn.harness.FnHarness.main(FnHarness.java:143)
at org.apache.beam.fn.harness.FnHarness.main(FnHarness.java:107)
