Repository: samza Updated Branches: refs/heads/master 72daa81d4 -> 89272b249
SAMZA-968: SequenceFileHdfsFileWriter does not close file properly Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/89272b24 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/89272b24 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/89272b24 Branch: refs/heads/master Commit: 89272b249d5dea203ce0c1b57e6a560648282958 Parents: 72daa81 Author: Benjamin Smith <[email protected]> Authored: Tue Jun 21 15:35:58 2016 -0700 Committer: Yi Pan (Data Infrastructure) <[email protected]> Committed: Tue Jun 21 15:35:58 2016 -0700 ---------------------------------------------------------------------- .../apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/89272b24/samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala ---------------------------------------------------------------------- diff --git a/samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala b/samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala index 46ade33..aa0e075 100644 --- a/samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala +++ b/samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala @@ -108,7 +108,7 @@ abstract class SequenceFileHdfsWriter(dfs: FileSystem, systemName: String, confi Some( SequenceFile.createWriter( dfs.getConf, - Writer.stream(dfs.create(path)), + Writer.file(path), Writer.keyClass(keyClass), Writer.valueClass(valueClass), Writer.compression(
