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 <31855286+gkovel...@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):