[
https://issues.apache.org/jira/browse/BEAM-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yichi Zhang updated BEAM-12294:
-------------------------------
Description:
Example worker error:
{code:java}
*~*~*~ 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)
{code}
was:
Example worker error:
{code:java}
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)
{code}
> BeamFnStatusClient managed channel not properly shutdown.
> ---------------------------------------------------------
>
> Key: BEAM-12294
> URL: https://issues.apache.org/jira/browse/BEAM-12294
> Project: Beam
> Issue Type: Bug
> Components: sdk-java-harness
> Reporter: Yichi Zhang
> Priority: P2
>
> Example worker error:
>
> {code:java}
> *~*~*~ 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)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
