-
Notifications
You must be signed in to change notification settings - Fork 4.5k
[BEAM-7173] Avoiding schema autodetection by default in WriteToBigQuery #8473
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
Run Python PreCommit |
|
Run Python PostCommit |
|
Run Python Postcommit |
| | "WriteWithMultipleDests2" >> beam.io.gcp.bigquery.WriteToBigQuery( | ||
| table=value_provider.StaticValueProvider( | ||
| str, '%s:%s' % (self.project, output_table_2)), | ||
| schema=bigquery.SCHEMA_AUTODETECT, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Note that SCHEMA_AUTODETECT does not work if BQ has to ingest bytes data into a table that has bytes field.
Also, should we have a test with and without autodetect behavior?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There are tests with and without this feature running in that file. WDYT?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think that should be fine and we don't need to duplicate every test twice, but you might want to do a one-off run of integration tests where the value of autodetection flag is changed to the opposite value, to make sure there are no surprises.
|
I think we should loop in Cham, who reviewed previous BQ PRs, perhaps once the tests pass. |
|
Run Python PostCommit |
3 similar comments
|
Run Python PostCommit |
|
Run Python PostCommit |
|
Run Python PostCommit |
|
Run Portable_Python PreCommit |
|
Run Python Precommit |
|
Run Python PostCommit |
2 similar comments
|
Run Python PostCommit |
|
Run Python PostCommit |
|
Run Python PostCommit |
|
LGTM, thank you! Please squash commits before the merge. |
@tvalentyn
cc: @aaltay