[beam] branch master updated: [BEAM-5315] Fix Py3 incompatibility in tfrecordio_test.

[ma...@apache.org]

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

markliu 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 681b8db  [BEAM-5315] Fix Py3 incompatibility in tfrecordio_test.
     new d0de455  Merge pull request #8852 from tvalentyn/patch-53
681b8db is described below

commit 681b8db0ac87490db3488cf4bd2f9e3473a3756c
Author: tvalentyn <tv...@users.noreply.github.com>
AuthorDate: Thu Jun 13 11:58:00 2019 -0700

    [BEAM-5315] Fix Py3 incompatibility in tfrecordio_test.
---
 sdks/python/apache_beam/io/tfrecordio_test.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/io/tfrecordio_test.py b/sdks/python/apache_beam/io/tfrecordio_test.py
index f003c34..c0a3c2d 100644
--- a/sdks/python/apache_beam/io/tfrecordio_test.py
+++ b/sdks/python/apache_beam/io/tfrecordio_test.py
@@ -216,7 +216,7 @@ class TestWriteToTFRecord(TestTFRecordSink):
     with TempDir() as temp_dir:
       file_path_prefix = temp_dir.create_temp_file('result')
       with TestPipeline() as p:
-        input_data = ['foo', 'bar']
+        input_data = [b'foo', b'bar']
         _ = p | beam.Create(input_data) | WriteToTFRecord(
             file_path_prefix, compression_type=CompressionTypes.GZIP)
 
@@ -232,7 +232,7 @@ class TestWriteToTFRecord(TestTFRecordSink):
     with TempDir() as temp_dir:
       file_path_prefix = temp_dir.create_temp_file('result')
       with TestPipeline() as p:
-        input_data = ['foo', 'bar']
+        input_data = [b'foo', b'bar']
         _ = p | beam.Create(input_data) | WriteToTFRecord(
             file_path_prefix, file_name_suffix='.gz')