diff --git a/velox/common/file/FileSystems.cpp b/velox/common/file/FileSystems.cpp index 7e41429694c0..2eadf2c03153 100644 --- a/velox/common/file/FileSystems.cpp +++ b/velox/common/file/FileSystems.cpp @@ -95,7 +95,12 @@ class LocalFileSystem : public FileSystem { "LocalReadahead")) : nullptr) {} - ~LocalFileSystem() override {} + ~LocalFileSystem() override { + if (executor_) { + executor_->stop(); + LOG(INFO) << "Executor " << executor_->getName() << " stopped."; + } + } std::string name() const override { return "Local FS";