【发布时间】:2019-08-21 12:55:44
【问题描述】:
作为 POC 的一部分,我尝试通过 Dataprep 设置一些数据质量检查。 有一个 BigQuery 表作为源,它应该运行一个输出到另一个 BigQuery 的作业。 不幸的是,该作业因错误而失败:
java.lang.RuntimeException: Failed to create job with prefix beam_load_[thenameofthejob], reached max retries: 3, last failed job: null.
at org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers$PendingJob.runJob(BigQueryHelpers.java:196)
at org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers$PendingJobManager.waitForDone(BigQueryHelpers.java:149)
at org.apache.beam.sdk.io.gcp.bigquery.WriteTables$WriteTablesDoFn.finishBundle(WriteTables.java:255) .
请问您有什么解决办法吗?
我已经编辑了食谱并且没有设置任何转换只是为了查看作业是否运行 - 它再次失败。 当我将此 dataprep 数据流输出到 csv 时,它可以工作。 全部在欧盟地区运行。
【问题讨论】:
-
你解决了吗?
标签: java google-bigquery google-cloud-dataprep