[GitHub] [flink] haf edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

[GitBox <gi...@apache.org>]

haf edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-481330654
 
 
   When I run this code with Flink 1.7, I get this critical error when things crash:
   
   ```
   Apr 09, 2019 6:44:17 PM io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference cleanQueue
   SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=5, target=pubsub.googleapis.com:443} was not shutdown properly!!! ~*~*~*
       Make sure to call shutdown()/shutdownNow() and wait until awaitTermination() returns true.
   java.lang.RuntimeException: ManagedChannel allocation site
   	at io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:103)
   	at io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)
   	at io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)
   	at io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:419)
   	at com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:222)
   	at com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:164)
   	at com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:156)
   	at com.google.api.gax.rpc.ClientContext.create(ClientContext.java:157)
   	at com.google.cloud.pubsub.v1.stub.GrpcSubscriberStub.create(GrpcSubscriberStub.java:260)
   	at okr.sources.DefaultPubSubSubscriberFactory.getSubscriber(DefaultPubSubSubscriberFactory.java:30)
   	at okr.sources.PubSubSource.open(PubSubSource.java:96)
   	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
   	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
   	at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424)
   	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290)
   	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:704)
   	at java.lang.Thread.run(Thread.java:748)
   ```
   
   While it's bad that my code crashes, I would not want this message in my production logs anyway. Perhaps the subscriber should be disposed in a different manner upon the remainder of the pipeline failing?

----------------------------------------------------------------
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:
users@infra.apache.org


With regards,
Apache Git Services