Skip to content

Commit aa47f26

Browse files
committed
use createWriter instead of SequenceFile.Writer
1 parent 8753168 commit aa47f26

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/org/apache/sysds/runtime/io/WriterBinaryBlock.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,8 @@ public long writeMatrixFromStream(String fname, LocalTaskQueue<IndexedMatrixValu
248248
long totalNnz = 0;
249249
try {
250250
// 1. Create Sequence file writer for the final destination file
251-
writer = new SequenceFile.Writer(fs, conf, path, MatrixIndexes.class, MatrixBlock.class);
251+
// writer = new SequenceFile.Writer(fs, conf, path, MatrixIndexes.class, MatrixBlock.class);
252+
writer = SequenceFile.createWriter(fs, conf, path, MatrixIndexes.class, MatrixBlock.class);
252253

253254
// 2. Loop through OOC stream
254255
IndexedMatrixValue i_val = null;

0 commit comments

Comments
 (0)