This is an automated email from the ASF dual-hosted git repository. pabloem pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new 358babb Fix broken BQ Integration Test (#15352) 358babb is described below commit 358babbd1549a01404c5d36b89d5a2c5296cd2cc Author: Sayat <saya...@gmail.com> AuthorDate: Thu Aug 19 09:15:34 2021 -0700 Fix broken BQ Integration Test (#15352) * Fix broken test * Fix issue with update schema source format Co-authored-by: Sayat <stb.satyb...@gmail.com> Co-authored-by: Sayat Satybaldiyev <sayat.satybaldi...@getcruise.com> --- sdks/python/apache_beam/io/gcp/bigquery_write_it_test.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/sdks/python/apache_beam/io/gcp/bigquery_write_it_test.py b/sdks/python/apache_beam/io/gcp/bigquery_write_it_test.py index 3e0c641..279c884 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery_write_it_test.py +++ b/sdks/python/apache_beam/io/gcp/bigquery_write_it_test.py @@ -396,9 +396,12 @@ class BigQueryWriteIntegrationTests(unittest.TestCase): args = self.test_pipeline.get_full_options_as_args( on_success_matcher=BigqueryFullResultMatcher( project=self.project, - query= - "SELECT bytes, date, time, int64, bool, nested_field.fruit FROM %s" - % table_id, + query=""" + SELECT bytes, date, time, int64, bool, fruit + FROM %s, + UNNEST(nested_field) as nested_field + ORDER BY int64 + """ % table_id, data=[(None, None, None, num, True, "Apple") for num in range(1, 3)]))