我正在运行一个数据流作业来从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)请帮我解决这个错误。如果我没有错,这是不是在获取刷新的访问令牌时出现的问题?
提前谢谢你
发布于 2018-12-20 14:31:48
当我们离开一段时间并等待下一个访问令牌时,数据流将继续运行,并按预期获取值。但还是找不到根本原因。是不是因为网络问题导致请求和响应延迟?
https://stackoverflow.com/questions/53848015
复制相似问题