[beam] branch master updated: [BEAM-6821] FileBasedSink improper paths (#8054)

[ch...@apache.org]

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

chamikara 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 13fcf78  [BEAM-6821] FileBasedSink improper paths (#8054)
13fcf78 is described below

commit 13fcf7851a1e68e3078a924df3e845ecb42bdf3c
Author: gkovelman <31...@users.noreply.github.com>
AuthorDate: Sat Jun 8 01:22:57 2019 +0300

    [BEAM-6821] FileBasedSink improper paths (#8054)
---
 sdks/python/apache_beam/io/filebasedsink.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/io/filebasedsink.py b/sdks/python/apache_beam/io/filebasedsink.py
index a7eb424..3e91470 100644
--- a/sdks/python/apache_beam/io/filebasedsink.py
+++ b/sdks/python/apache_beam/io/filebasedsink.py
@@ -182,7 +182,8 @@ class FileBasedSink(iobase.Sink):
     file_name_suffix = self.file_name_suffix.get()
     suffix = (
         '.' + os.path.basename(file_path_prefix) + file_name_suffix)
-    return FileBasedSinkWriter(self, os.path.join(init_result, uid) + suffix)
+    writer_path = FileSystems.join(init_result, uid) + suffix
+    return FileBasedSinkWriter(self, writer_path)
 
   @check_accessible(['file_path_prefix', 'file_name_suffix'])
   def _get_final_name(self, shard_num, num_shards):