[
https://issues.apache.org/jira/browse/BEAM-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511084#comment-17511084
]
Joachim Isaksson commented on BEAM-12356:
-----------------------------------------
Sure, here's a couple more different from Claire's from one of our current
builds (apparently) related to pubsub and policy tags;
{{2022-03-22T18:16:47.6624939Z Mar 22, 2022 6:15:37 PM
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue}}
{{2022-03-22T18:16:47.6625821Z SEVERE: *~*~*~ Channel
ManagedChannelImpl\{logId=1, target=pubsub.googleapis.com:443} was not shutdown
properly!!! ~*~*~*}}
{{2022-03-22T18:16:47.6626574Z Make sure to call shutdown()/shutdownNow() and
wait until awaitTermination() returns true.}}
{{2022-03-22T18:16:47.6627168Z java.lang.RuntimeException: ManagedChannel
allocation site}}
{{2022-03-22T18:16:47.6627872Z at
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:93)}}
{{2022-03-22T18:16:47.6628693Z at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)}}
{{2022-03-22T18:16:47.6629439Z at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)}}
{{2022-03-22T18:16:47.6630180Z at
io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:630)}}
{{2022-03-22T18:16:47.6630961Z at
io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:297)}}
{{2022-03-22T18:16:47.6631827Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:395)}}
{{2022-03-22T18:16:47.6632719Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.access$1900(InstantiatingGrpcChannelProvider.java:82)}}
{{2022-03-22T18:16:47.6633621Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider$1.createSingleChannel(InstantiatingGrpcChannelProvider.java:240)}}
{{2022-03-22T18:16:47.6634379Z at
com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:72)}}
{{2022-03-22T18:16:47.6635132Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:250)}}
{{2022-03-22T18:16:47.6636130Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:228)}}
{{2022-03-22T18:16:47.6636936Z at
com.google.api.gax.rpc.ClientContext.create(ClientContext.java:205)}}
{{2022-03-22T18:16:47.6637637Z at
com.google.cloud.pubsub.v1.stub.GrpcSubscriberStub.create(GrpcSubscriberStub.java:287)}}
{{2022-03-22T18:16:47.6638409Z at
com.google.cloud.pubsub.v1.stub.SubscriberStubSettings.createStub(SubscriberStubSettings.java:369)}}
{{2022-03-22T18:16:47.6639192Z at
com.google.cloud.pubsub.v1.SubscriptionAdminClient.<init>(SubscriptionAdminClient.java:177)}}
{{2022-03-22T18:16:47.6639964Z at
com.google.cloud.pubsub.v1.SubscriptionAdminClient.create(SubscriptionAdminClient.java:158)}}
{{2022-03-22T18:16:47.6640729Z at
com.google.cloud.pubsub.v1.SubscriptionAdminClient.create(SubscriptionAdminClient.java:149)}}
{{2022-03-22T18:16:47.6641567Z at
com.xxx.xxx.common.pipeline.SubscriptionHelper.createSubscriptionIfItDoesNotExist(SubscriptionHelper.kt:64)}}
{{2022-03-22T18:16:47.6642570Z at
com.xxx.xxx.common.pipeline.SubscriptionHelperTest.createSubscriptionIfItDoesNotExist_SubscriptionIsCreated(SubscriptionHelperTest.kt:135)}}
{{2022-03-22T18:16:47.6643428Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)}}
{{2022-03-22T18:16:47.6644135Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)}}
{{2022-03-22T18:16:47.6644943Z at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)}}
{{2022-03-22T18:16:47.6645649Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)}}
{{2022-03-22T18:16:47.6646416Z at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)}}
{{2022-03-22T18:16:47.6647138Z at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)}}
{{2022-03-22T18:16:47.6648131Z at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)}}
{{2022-03-22T18:16:47.6650214Z at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)}}
{{2022-03-22T18:16:47.6651027Z at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)}}
{{2022-03-22T18:16:47.6651848Z at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)}}
{{2022-03-22T18:16:47.6652732Z at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)}}
{{2022-03-22T18:16:47.6653930Z at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)}}
{{2022-03-22T18:16:47.6654939Z at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)}}
{{2022-03-22T18:16:47.6656004Z at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)}}
{{2022-03-22T18:16:47.6656869Z at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)}}
{{2022-03-22T18:16:47.6658026Z at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)}}
{{2022-03-22T18:16:47.6658824Z at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)}}
{{2022-03-22T18:16:47.6659569Z at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)}}
{{2022-03-22T18:16:47.6660405Z at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)}}
{{2022-03-22T18:16:47.6661285Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6662133Z at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)}}
{{2022-03-22T18:16:47.6662970Z at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)}}
{{2022-03-22T18:16:47.6663957Z at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)}}
{{2022-03-22T18:16:47.6665931Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)}}
{{2022-03-22T18:16:47.6666795Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6667637Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)}}
{{2022-03-22T18:16:47.6668421Z at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)}}
{{2022-03-22T18:16:47.6669192Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)}}
{{2022-03-22T18:16:47.6670033Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6670852Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)}}
{{2022-03-22T18:16:47.6671638Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)}}
{{2022-03-22T18:16:47.6672600Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)}}
{{2022-03-22T18:16:47.6673777Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)}}
{{2022-03-22T18:16:47.6675119Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)}}
{{2022-03-22T18:16:47.6676107Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)}}
{{2022-03-22T18:16:47.6676954Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6677792Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)}}
{{2022-03-22T18:16:47.6678560Z at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)}}
{{2022-03-22T18:16:47.6679324Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)}}
{{2022-03-22T18:16:47.6680143Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6680970Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)}}
{{2022-03-22T18:16:47.6681758Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)}}
{{2022-03-22T18:16:47.6682714Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)}}
{{2022-03-22T18:16:47.6683637Z at
java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)}}
{{2022-03-22T18:16:47.6684308Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)}}
{{2022-03-22T18:16:47.6684962Z at
java.base/java.util.concurrent.ForkJoinTask.doJoin(ForkJoinTask.java:396)}}
{{2022-03-22T18:16:47.6685614Z at
java.base/java.util.concurrent.ForkJoinTask.join(ForkJoinTask.java:721)}}
{{2022-03-22T18:16:47.6686604Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.joinConcurrentTasksInReverseOrderToEnableWorkStealing(ForkJoinPoolHierarchicalTestExecutorService.java:162)}}
{{2022-03-22T18:16:47.6687827Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:136)}}
{{2022-03-22T18:16:47.6688816Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)}}
{{2022-03-22T18:16:47.6689757Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6690624Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)}}
{{2022-03-22T18:16:47.6691390Z at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)}}
{{2022-03-22T18:16:47.6692156Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)}}
{{2022-03-22T18:16:47.6692996Z at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)}}
{{2022-03-22T18:16:47.6693819Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)}}
{{2022-03-22T18:16:47.6694606Z at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)}}
{{2022-03-22T18:16:47.6695544Z at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)}}
{{2022-03-22T18:16:47.6696470Z at
java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)}}
{{2022-03-22T18:16:47.6697144Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)}}
{{2022-03-22T18:16:47.6698220Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)}}
{{2022-03-22T18:16:47.6698926Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)}}
{{2022-03-22T18:16:47.6699736Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)}}
{{2022-03-22T18:16:47.6700437Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)}}
{{2022-03-22T18:16:49.7726196Z Mar 22, 2022 6:15:40 PM
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue}}
{{2022-03-22T18:16:49.7727327Z SEVERE: *~*~*~ Channel
ManagedChannelImpl\{logId=7, target=datacatalog.googleapis.com:443} was not
shutdown properly!!! ~*~*~*}}
{{2022-03-22T18:16:49.7728028Z Make sure to call shutdown()/shutdownNow() and
wait until awaitTermination() returns true.}}
{{2022-03-22T18:16:49.7728576Z java.lang.RuntimeException: ManagedChannel
allocation site}}
{{2022-03-22T18:16:49.7729211Z at
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:93)}}
{{2022-03-22T18:16:49.7730155Z at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)}}
{{2022-03-22T18:16:49.7731159Z at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)}}
{{2022-03-22T18:16:49.7732072Z at
io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:630)}}
{{2022-03-22T18:16:49.7733015Z at
io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:297)}}
{{2022-03-22T18:16:49.7734040Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:395)}}
{{2022-03-22T18:16:49.7734896Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.access$1900(InstantiatingGrpcChannelProvider.java:82)}}
{{2022-03-22T18:16:49.7735968Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider$1.createSingleChannel(InstantiatingGrpcChannelProvider.java:240)}}
{{2022-03-22T18:16:49.7736720Z at
com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:72)}}
{{2022-03-22T18:16:49.7737573Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:250)}}
{{2022-03-22T18:16:49.7738445Z at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:228)}}
{{2022-03-22T18:16:49.7739187Z at
com.google.api.gax.rpc.ClientContext.create(ClientContext.java:205)}}
{{2022-03-22T18:16:49.7740016Z at
com.google.cloud.datacatalog.v1beta1.stub.GrpcPolicyTagManagerStub.create(GrpcPolicyTagManagerStub.java:221)}}
{{2022-03-22T18:16:49.7740854Z at
com.google.cloud.datacatalog.v1beta1.stub.PolicyTagManagerStubSettings.createStub(PolicyTagManagerStubSettings.java:313)}}
{{2022-03-22T18:16:49.7742023Z at
com.google.cloud.datacatalog.v1beta1.PolicyTagManagerClient.<init>(PolicyTagManagerClient.java:143)}}
{{2022-03-22T18:16:49.7742950Z at
com.google.cloud.datacatalog.v1beta1.PolicyTagManagerClient.create(PolicyTagManagerClient.java:124)}}
{{2022-03-22T18:16:49.7743724Z at
com.google.cloud.datacatalog.v1beta1.PolicyTagManagerClient.create(PolicyTagManagerClient.java:115)}}
{{2022-03-22T18:16:49.7745178Z at
com.xxx.xxx.common.utility.PolicyHelper.getPolicyForProject(PolicyHelper.kt:21)}}
{{2022-03-22T18:16:49.7746724Z at
com.xxx.xxx.common.utility.PolicyHelper.getPiiPolicyTagName$lambda-0(PolicyHelper.kt:17)}}
{{2022-03-22T18:16:49.7747496Z at
java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705)}}
{{2022-03-22T18:16:49.7748301Z at
com.xxx.xxx.common.utility.PolicyHelper.getPiiPolicyTagName(PolicyHelper.kt:16)}}
{{2022-03-22T18:16:49.7749083Z at
com.xxx.xxx.common.pipeline.TableDestinationFinder.addPolicyTags(TableDestinationFinder.kt:105)}}
{{2022-03-22T18:16:49.7750357Z at
com.xxx.xxx.common.pipeline.TableDestinationFinder.getSchema$lambda-0(TableDestinationFinder.kt:67)}}
{{2022-03-22T18:16:49.7751196Z at
java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705)}}
{{2022-03-22T18:16:49.7751989Z at
com.xxx.xxx.common.pipeline.TableDestinationFinder.getSchema(TableDestinationFinder.kt:64)}}
{{2022-03-22T18:16:49.7752795Z at
com.xxx.xxx.common.pipeline.TableDestinationFinder.getSchema(TableDestinationFinder.kt:32)}}
{{2022-03-22T18:16:49.7753638Z at
org.apache.beam.sdk.io.gcp.bigquery.CreateTables$CreateTablesFn.lambda$processElement$0(CreateTables.java:114)}}
{{2022-03-22T18:16:49.7754469Z at
org.apache.beam.sdk.io.gcp.bigquery.CreateTableHelpers.tryCreateTable(CreateTableHelpers.java:114)}}
{{2022-03-22T18:16:49.7755489Z at
org.apache.beam.sdk.io.gcp.bigquery.CreateTableHelpers.possiblyCreateTable(CreateTableHelpers.java:86)}}
{{2022-03-22T18:16:49.7756349Z at
org.apache.beam.sdk.io.gcp.bigquery.CreateTables$CreateTablesFn.lambda$processElement$1(CreateTables.java:115)}}
{{2022-03-22T18:16:49.7757120Z at
java.base/java.util.HashMap.computeIfAbsent(HashMap.java:1133)}}
{{2022-03-22T18:16:49.7757834Z at
org.apache.beam.sdk.io.gcp.bigquery.CreateTables$CreateTablesFn.processElement(CreateTables.java:104)}}
{{2022-03-22T18:16:49.7758774Z at
org.apache.beam.sdk.io.gcp.bigquery.CreateTables$CreateTablesFn$DoFnInvoker.invokeProcessElement(Unknown
Source)}}
{{2022-03-22T18:16:49.7759639Z at
org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:228)}}
{{2022-03-22T18:16:49.7760926Z at
org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:187)}}
{{2022-03-22T18:16:49.7762416Z at
org.apache.beam.repackaged.direct_java.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:79)}}
{{2022-03-22T18:16:49.7763310Z at
org.apache.beam.runners.direct.ParDoEvaluator.processElement(ParDoEvaluator.java:244)}}
{{2022-03-22T18:16:49.7764183Z at
org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:54)}}
{{2022-03-22T18:16:49.7765677Z at
org.apache.beam.runners.direct.DirectTransformExecutor.processElements(DirectTransformExecutor.java:165)}}
{{2022-03-22T18:16:49.7766472Z at
org.apache.beam.runners.direct.DirectTransformExecutor.run(DirectTransformExecutor.java:129)}}
{{2022-03-22T18:16:49.7767181Z at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)}}
{{2022-03-22T18:16:49.7767814Z at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)}}
{{2022-03-22T18:16:49.7768453Z at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)}}
{{2022-03-22T18:16:49.7769163Z at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)}}
{{2022-03-22T18:16:49.7769764Z at
java.base/java.lang.Thread.run(Thread.java:829)}}
{{2022-03-22T18:16:49.7770011Z}}
> BigQueryWriteClient in DatasetServiceImpl is not closed, which causes
> "ManagedChannel allocation site" exceptions
> -----------------------------------------------------------------------------------------------------------------
>
> Key: BEAM-12356
> URL: https://issues.apache.org/jira/browse/BEAM-12356
> Project: Beam
> Issue Type: Bug
> Components: io-java-gcp
> Affects Versions: 2.29.0, 2.32.0, 2.33.0
> Reporter: Minbo Bae
> Assignee: Reuven Lax
> Priority: P2
> Fix For: 2.34.0
>
> Attachments: bigquery_grpc.log
>
> Time Spent: 5.5h
> Remaining Estimate: 0h
>
> [BigQueryWriteClient|https://github.com/apache/beam/blob/v2.29.0/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java#L461]
> in DatasetServiceImpl (added at [https://github.com/apache/beam/pull/14309)]
> is not closed. This causes the error logs in gRPC orphan channel clean up.
> See "bigquery_grpc.log" in attachments which is extracted from GCP Dataflow.
> I don't think this issue affect pipeline runs except the error logs, but
> could you take a look at that?
> A similar issue is reported for {{CloudBigtableIO}} at
> [https://github.com/googleapis/java-bigtable-hbase/issues/2658]
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
