刷新google cloud d中的访问令牌时发生GRPC status运行时异常

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

当我们离开一段时间并等待下一个访问令牌时，数据流将继续运行并按预期获取值。但还是找不出根本原因。是因为网络问题导致请求和响应延迟吗？你知道吗