You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "JBodkin (Jira)" <ji...@apache.org> on 2020/04/27 11:24:00 UTC
[jira] [Created] (BEAM-9828) BigQueryIO attempts to repeat the same
job id for batch load when the table does not exist
JBodkin created BEAM-9828:
-----------------------------
Summary: BigQueryIO attempts to repeat the same job id for batch load when the table does not exist
Key: BEAM-9828
URL: https://issues.apache.org/jira/browse/BEAM-9828
Project: Beam
Issue Type: Bug
Components: io-java-gcp
Affects Versions: 2.19.0
Reporter: JBodkin
I've noticed that BigQueryIO attempts to repeat the same job id for batch loading when the table does not exist. I believe this happens due to the check in `getJob` that looks at the status output. [https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java#L361]
The output from the GCP API for get job has the following:
{code:java}
"status": {
"errorResult": {
"message": "Not found: Table xxx was not found in location europe-west2",
"reason": "notFound"
},
"errors": [
{
"message": "Not found: Table xxx was not found in location europe-west2",
"reason": "notFound"
}
],
"state": "DONE"
},
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)