[beam] branch master updated: [BEAM-8217] Encode str to bytes py3 in sdk harness status server

[al...@apache.org]

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

altay 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 b82b96b  [BEAM-8217] Encode str to bytes py3 in sdk harness status server
     new abf00f4  Merge pull request #9551 from angoenka/fix_py3_status_serever
b82b96b is described below

commit b82b96b190d50945cce8958985006612f375113d
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Wed Sep 11 16:18:31 2019 -0700

    [BEAM-8217] Encode str to bytes py3 in sdk harness status server
---
 sdks/python/apache_beam/runners/worker/sdk_worker_main.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
index f28703e..94ce343 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
@@ -74,7 +74,7 @@ class StatusServer(object):
         self.end_headers()
 
         for line in StatusServer.get_thread_dump():
-          self.wfile.write(line)
+          self.wfile.write(line.encode('utf-8'))
 
       def log_message(self, f, *args):
         """Do not log any messages."""