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)]))