Fix error

src/IO/AsynchronousReadBufferFromFile.cpp

@@ -71,6 +71,9 @@ AsynchronousReadBufferFromFile::AsynchronousReadBufferFromFile(
 
 AsynchronousReadBufferFromFile::~AsynchronousReadBufferFromFile()
 {
+    /// Must wait for events in flight before closing the file.
+    finalize();
+
     if (fd < 0)
         return;
 
@@ -89,5 +92,13 @@ void AsynchronousReadBufferFromFile::close()
     fd = -1;
 }
 
+
+AsynchronousReadBufferFromFileWithCache::~AsynchronousReadBufferFromFileWithCache()
+{
+    /// Must wait for events in flight before potentially closing the file by destroying OpenedFilePtr.
+    finalize();
+}
+
+
 }
 

src/IO/AsynchronousReadBufferFromFile.h

@@ -58,6 +58,8 @@ public:
         fd = file->getFD();
     }
 
+    ~AsynchronousReadBufferFromFileWithCache() override;
+
     std::string getFileName() const override
     {
         return file_name;

src/IO/AsynchronousReadBufferFromFileDescriptor.cpp

@@ -62,7 +62,7 @@ bool AsynchronousReadBufferFromFileDescriptor::nextImpl()
 }
 
 
-AsynchronousReadBufferFromFileDescriptor::~AsynchronousReadBufferFromFileDescriptor()
+void AsynchronousReadBufferFromFileDescriptor::finalize()
 {
     if (prefetch_request_id)
     {
@@ -72,6 +72,12 @@ AsynchronousReadBufferFromFileDescriptor::~AsynchronousReadBufferFromFileDescrip
 }
 
 
+AsynchronousReadBufferFromFileDescriptor::~AsynchronousReadBufferFromFileDescriptor()
+{
+    finalize();
+}
+
+
 /// If 'offset' is small enough to stay in buffer after seek, then true seek in file does not happen.
 off_t AsynchronousReadBufferFromFileDescriptor::seek(off_t offset, int whence)
 {

src/IO/AsynchronousReadBufferFromFileDescriptor.h

@@ -30,6 +30,8 @@ protected:
     /// Name or some description of file.
     std::string getFileName() const override;
 
+    void finalize();
+
 public:
     AsynchronousReadBufferFromFileDescriptor(
         AsynchronousReaderPtr reader_,