You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Jeff Webb (Jira)" <ji...@apache.org> on 2021/09/14 22:58:00 UTC

[jira] [Updated] (BEAM-9828) BigQueryIO attempts to repeat the same job id for batch load when the table does not exist

     [ https://issues.apache.org/jira/browse/BEAM-9828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jeff Webb updated BEAM-9828:
----------------------------
    Resolution: Won't Fix
        Status: Resolved  (was: Triage Needed)

old issue - resolving

 

> 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
>            Priority: P3
>
> 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)