mirrors/arrow
0
0 Fork 0
mirror of https://github.com/apache/arrow.git synced 2026-10-29 17:15:39 +08:00
Code Activity

Close BufferOutputStream after completing file or stream writes

Browse Source 
Change-Id: I0116b58544db8576b1875463dbbc70849a456e9c
This commit is contained in:
Wes McKinney committed 2017-01-23 06:42:24 -05:00
1 parent 31e519f744
commit e9d918ed9b
1 file changed
+2
Download Patch File Download Diff File Expand all files Collapse all files
cpp/src/arrow/ipc/ipc-file-test.cc
+2
View File
@@ -75,6 +75,7 @@ class TestFileFormat : public ::testing::TestWithParam<MakeRecordBatch*> {
RETURN_NOT_OK(writer->WriteRecordBatch(*batch));
}
RETURN_NOT_OK(writer->Close());
RETURN_NOT_OK(sink_->Close());
// Current offset into stream is the end of the file
int64_t footer_offset;
@@ -138,6 +139,7 @@ class TestStreamFormat : public ::testing::TestWithParam<MakeRecordBatch*> {
RETURN_NOT_OK(writer->WriteRecordBatch(batch));
}
RETURN_NOT_OK(writer->Close());
RETURN_NOT_OK(sink_->Close());
// Open the file
auto buf_reader = std::make_shared<io::BufferReader>(buffer_);