我正在运行数据流作业以从 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)
请帮我解决这个错误。 如果我没记错的话，这是获取刷新访问 token 时的问题吗？
提前谢谢
最佳答案
当我们离开一段时间并等待下一个访问 token 时，数据流将继续运行并按预期获取值。但还是没能找出根本原因。是否因为网络问题导致请求和响应延迟？
关于python - 在谷歌云数据流中刷新访问 token 时，GRPC 状态运行时异常，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53848015/