时间戳

首页 > 解决方案 > 在谷歌云数据流中刷新访问令牌时 GRPC 状态运行时异常

python - 在谷歌云数据流中刷新访问令牌时 GRPC 状态运行时异常

问题描述

我正在运行数据流作业以从 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)

请帮我解决错误。如果我没记错的话，这是刷新访问令牌时的问题吗？

先感谢您

标签： pythonaccess-tokenapache-beamdataflow

解决方案

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

推荐阅读