rmetzger commented 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-468689632 > I currently see one exception quite often: `DEADLINE_EXCEEDED` which is basically a timeout. My guess is this tail latency. My flink cluster is behind some firewalls on a gcp kubernetes cluster and we just need some higher default timeouts. I am curious if you run into the same exception. I don't see that exception. What I see for the sink is the following: ``` 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring DATA frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring DATA frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring DATA frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring DATA frame for stream RST_STREAM sent. {} 15:34:34,803 INFO io.grpc.netty.shaded.io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder - [id: 0x0568ec6c, L:/192.168.1.6:57417 - R:pubsub.googleapis.com/172.217.20.106:443] ignoring HEADERS frame for stream RST_STREAM sent. {} ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
