stankiewicz opened a new pull request, #40616: URL: https://github.com/apache/beam/pull/40616
In SpannerIO.ReadChangeStream, buildChangeStreamSpannerConfig() configures ExecuteStreamingSqlRetrySettings with initialRpcTimeout = 1 minute and totalTimeout = 5 minutes, while QueryChangeStreamAction uses a 40-second soft RestrictionInterrupter that is only evaluated between resultSet.next() calls. Any resultSet.next() call that blocks past the 60-second RPC timeout fails with DEADLINE_EXCEEDED. Add Code.DEADLINE_EXCEEDED to defaultRetryableCodes alongside Code.UNAVAILABLE and Code.ABORTED so google-cloud-spanner's ResumableStreamIterator can transparently resume the change stream query from the last resume_token without failing the in-flight bundle. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
