PubSub Synchronous Pull hang

[flascaray]

I'm using the synchronous pull to retrive events. My code is based on the Google documentation (https://cloud.google.com/pubsub/docs/pull)

When I call the following method the thread is blocked indefinitely. I paste you the logs.

Thanks

subscriber.pullCallable().call(pullRequest)

20405 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.n.handler.ssl.SslHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] HANDSHAKEN: TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305_SHA256 
20405 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] OUTBOUND SETTINGS: ack=false settings={ENABLE_PUSH=0, MAX_CONCURRENT_STREAMS=0, INITIAL_WINDOW_SIZE=1048576, MAX_HEADER_LIST_SIZE=8192} 
20405 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] OUTBOUND WINDOW_UPDATE: streamId=0 windowSizeIncrement=983041 
20407 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] INBOUND SETTINGS: ack=false settings={MAX_CONCURRENT_STREAMS=100, INITIAL_WINDOW_SIZE=1048576, MAX_HEADER_LIST_SIZE=16384} 
20407 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] OUTBOUND SETTINGS: ack=true 
20414 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] INBOUND WINDOW_UPDATE: streamId=0 windowSizeIncrement=983041 
20414 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] OUTBOUND HEADERS: streamId=3 headers=GrpcHttp2OutboundHeaders[:authority: pubsub.googleapis.com:443, :path: /google.pubsub.v1.Subscriber/Pull, :method: POST, :scheme: https, content-type: application/grpc, te: trailers, user-agent: grpc-java-netty/1.13.1, x-goog-api-client: gl-java/ gapic/1.46.0 gax/1.32.0 grpc/1.13.1, grpc-accept-encoding: gzip, authorization: Bearer ya29.Gl0mBujH07mMLwNgT82zS1UPHvO2mI-i722sRPAloMt_7VhC2fH-DYG4nKxRE4jLM_6-15NPBEG2ZtjAzSz4vHeHNpBEiXHJZiBy615vphO8gdJ4ByxX65Z--8t4j2Y, grpc-trace-bin: AABdNAaFMePVCGCr/ImmLt5LAS7dwboVxNSMAgA=, grpc-timeout: 11930421u] streamDependency=0 weight=16 exclusive=false padding=0 endStream=false 
20415 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] OUTBOUND DATA: streamId=3 padding=0 endStream=true length=91 bytes=00000000560a5270726f6a656374732f6a632d70726570726f2d626c75652d636f6c6c61722f737562736372697074696f6e732f6c6f63616c2d6a6f622d6e6f... 
20416 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] INBOUND SETTINGS: ack=true 
32346 [grpc-default-worker-ELG-1-5] DEBUG i.g.n.s.i.g.n.NettyClientHandler - [id: 0x72c947db, L:/192.168.30.31:44592 - R:pubsub.googleapis.com/172.217.162.10:443] OUTBOUND RST_STREAM: streamId=3 errorCode=8 
89339 [ObjectCleanerThread] DEBUG i.g.n.s.i.n.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: ObjectCleanerThread 

[chingor13]

@pongad is this related to the fixes you are already working on?

[pongad]

This isn't related to the fix I was making. My fix was around Subscriber. The problem description here seems to suggest that the Pull RPC itself doesn't work.

[yuri-sergiichuk]

@flascaray try to set returnImmediately=true for your PullRequest. I guess we've experienced the same problem.

Here's what we're using:

PullRequest.newBuilder()
           .setMaxMessages(1)
           .setReturnImmediately(true)
           .setSubscription(subscription)
           .build();