[ https://issues.apache.org/jira/browse/BEAM-7742?focusedWorklogId=295189&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-295189 ]
ASF GitHub Bot logged work on BEAM-7742: ---------------------------------------- Author: ASF GitHub Bot Created on: 15/Aug/19 04:45 Start Date: 15/Aug/19 04:45 Worklog Time Spent: 10m Work Description: ttanay commented on issue #9242: [BEAM-7742] Partition files in BQFL to cater to quotas & limits URL: https://github.com/apache/beam/pull/9242#issuecomment-521511917 > Ah we discussed this, right? We need temp tables for dynamic dstinations : ) Yes. Making the change :hammer: ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking ------------------- Worklog Id: (was: 295189) Time Spent: 1h 40m (was: 1.5h) > BigQuery File Loads to work well with load job size limits > ---------------------------------------------------------- > > Key: BEAM-7742 > URL: https://issues.apache.org/jira/browse/BEAM-7742 > Project: Beam > Issue Type: Improvement > Components: io-py-gcp > Reporter: Pablo Estrada > Assignee: Tanay Tummalapalli > Priority: Major > Time Spent: 1h 40m > Remaining Estimate: 0h > > Load jobs into BigQuery have a number of limitations: > [https://cloud.google.com/bigquery/quotas#load_jobs] > > Currently, the python BQ sink implemented in `bigquery_file_loads.py` does > not handle these limitations well. Improvements need to be made to the > miplementation, to: > * Decide to use temp_tables dynamically at pipeline execution > * Add code to determine when a load job to a single destination needs to be > partitioned into multiple jobs. > * When this happens, then we definitely need to use temp_tables, in case one > of the two load jobs fails, and the pipeline is rerun. > Tanay, would you be able to look at this? -- This message was sent by Atlassian JIRA (v7.6.14#76016)