From 91986687e304648c282da1f906d2372b45759d6a Mon Sep 17 00:00:00 2001 From: Sayat Date: Wed, 18 Aug 2021 18:18:36 -0700 Subject: [PATCH 1/2] Fix broken test --- 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 3e0c641fb168..279c8847ec36 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 @@ def test_big_query_write_temp_table_append_schema_update(self): 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)])) From 6055eb69b3cddd9b6c12919bbacb7b2844755f89 Mon Sep 17 00:00:00 2001 From: Sayat Satybaldiyev Date: Tue, 27 Jul 2021 18:08:22 -0700 Subject: [PATCH 2/2] Fix issue with update schema source format