[beam] branch master updated: Fix broken BQ Integration Test (#15352)

[pa...@apache.org]

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 <sa...@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 <st...@gmail.com>
    Co-authored-by: Sayat Satybaldiyev <sa...@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)]))