Skip to content

Commit

Permalink
fix bug
Browse files Browse the repository at this point in the history
  • Loading branch information
loneylee committed Aug 14, 2024
1 parent 1a6bd1e commit 3619ccf
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -251,9 +251,8 @@ class HDFSFileReadBufferBuilder : public ReadBufferBuilder
if (file_size)
size = file_size;

auto read_buffer_impl = std::make_unique<DB::ReadBufferFromHDFS>(
auto read_buffer_impl = std::make_shared<DB::ReadBufferFromHDFS>(
uri_path, file_uri.getPath(), config, read_settings, read_util_position, true, size);
std::shared_ptr<DB::ReadBufferFromHDFS> impl = std::move(read_buffer_impl);
auto & pool_reader = context->getThreadPoolReader(DB::FilesystemReaderType::ASYNCHRONOUS_REMOTE_FS_READER);
read_buffer = std::make_unique<DB::AsynchronousReadBufferFromHDFS>(pool_reader, read_settings, std::move(read_buffer_impl));
}
Expand Down

0 comments on commit 3619ccf

Please sign in to comment.