thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 12:32:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
feng lv 2021-10-07 13:23:25 +00:00
parent 4841b31b56
commit 4233e2cca4
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Storages/FileLog/FileLogSource.cpp
View File

@ -1,5 +1,3 @@
#include <DataStreams/ConvertingBlockInputStream.h>
#include <DataStreams/OneBlockInputStream.h>
#include <Formats/FormatFactory.h> #include <Formats/FormatFactory.h>
#include <Interpreters/Context.h> #include <Interpreters/Context.h>
#include <Processors/Executors/StreamingFormatExecutor.h> #include <Processors/Executors/StreamingFormatExecutor.h>

5
src/Storages/FileLog/StorageFileLog.cpp
View File

@ -14,7 +14,6 @@
#include <Parsers/ASTLiteral.h> #include <Parsers/ASTLiteral.h>
#include <Processors/Executors/CompletedPipelineExecutor.h> #include <Processors/Executors/CompletedPipelineExecutor.h>
#include <Processors/Pipe.h> #include <Processors/Pipe.h>
#include <Processors/Transforms/ExpressionTransform.h>
#include <Storages/FileLog/FileLogSource.h> #include <Storages/FileLog/FileLogSource.h>
#include <Storages/FileLog/ReadBufferFromFileLog.h> #include <Storages/FileLog/ReadBufferFromFileLog.h>
#include <Storages/FileLog/StorageFileLog.h> #include <Storages/FileLog/StorageFileLog.h>
@ -484,8 +483,8 @@ void StorageFileLog::closeFilesAndStoreMeta(size_t start, size_t end)
if (file_ctx.reader) if (file_ctx.reader)
{ {
if ((*file_ctx.reader).is_open()) if (file_ctx.reader->is_open())
(*file_ctx.reader).close(); file_ctx.reader->close();
} }
auto & meta = findInMap(file_infos.meta_by_inode, file_ctx.inode); auto & meta = findInMap(file_infos.meta_by_inode, file_ctx.inode);