Исключение времени выполнения статуса GRPC при обновлении токена доступа в облачном потоке данных Google

Question

Я выполняю задание потока данных, чтобы извлечь данные из pubsub и перейти к большому запросу.Но во время этого процесса я получаю следующую ошибку после 1 часа пробега.

INFO:oauth2client.transport:Refreshing due to a 401 (attempt 1/2)
INFO:oauth2client.client:Refreshing access_token
INFO:root:2018-12-19T09:13:09.510Z: JOB_MESSAGE_ERROR: 
java.util.concurrent.ExecutionException: org.apache.beam.vendor.grpc.v1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close

java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
    java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
    org.apache.beam.sdk.util.MoreFutures.get(MoreFutures.java:57)

Пожалуйста, помогите мне разрешить ошибку.Если я не ошибаюсь, это проблема при обновлении токенов доступа?

Заранее спасибо

Answer 1

Когда мы уходим на некоторое время и ждем следующего токена доступа, поток данных продолжает работать и получает значения, как и ожидалось.Но все еще не мог понять причину.Это из-за проблем с сетью, когда запрос и ответ задерживаются?