You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2019/11/01 22:25:23 UTC

[beam] branch aaltay-patch-1 updated: Fix Table.from_arrays API change

This is an automated email from the ASF dual-hosted git repository.

altay pushed a commit to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/aaltay-patch-1 by this push:
     new c600ef5  Fix Table.from_arrays API change
     new 05deffa  Merge pull request #9971 from TheNeuralBit/aaltay-patch-1
c600ef5 is described below

commit c600ef5898930faf35631e6ebb32179d70f6e46b
Author: Brian Hulette <bh...@google.com>
AuthorDate: Fri Nov 1 14:44:07 2019 -0700

    Fix Table.from_arrays API change
---
 sdks/python/apache_beam/io/parquetio_test.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/io/parquetio_test.py b/sdks/python/apache_beam/io/parquetio_test.py
index 824341e..d6241bf 100644
--- a/sdks/python/apache_beam/io/parquetio_test.py
+++ b/sdks/python/apache_beam/io/parquetio_test.py
@@ -448,7 +448,7 @@ class TestParquet(unittest.TestCase):
   def test_selective_columns(self):
     file_name = self._write_data()
     orig = self._records_as_arrow()
-    expected_result = [pa.Table.from_arrays([orig.column('name')])]
+    expected_result = [pa.Table.from_arrays([orig.column('name')], names=['name'])]
     self._run_parquet_test(file_name, ['name'], None, False, expected_result)
 
   def test_sink_transform_multiple_row_group(self):