diff --git a/sstables/sstables.cc b/sstables/sstables.cc index 0190c7ed92..902233e820 100644 --- a/sstables/sstables.cc +++ b/sstables/sstables.cc @@ -1839,7 +1839,9 @@ input_stream sstable::data_stream(uint64_t pos, size_t len, const io_prior future> sstable::data_read(uint64_t pos, size_t len, const io_priority_class& pc) { return do_with(data_stream(pos, len, pc), [len] (auto& stream) { - return stream.read_exactly(len); + return stream.read_exactly(len).finally([&stream] { + return stream.close(); + }); }); }