From 4233e2cca452a3f987e774d1066194a68769e207 Mon Sep 17 00:00:00 2001
From: feng lv <fenglv15@mails.ucas.ac.cn>
Date: Thu, 7 Oct 2021 13:23:25 +0000
Subject: [PATCH] fix

---
 src/Storages/FileLog/FileLogSource.cpp  | 2 --
 src/Storages/FileLog/StorageFileLog.cpp | 5 ++---
 2 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/src/Storages/FileLog/FileLogSource.cpp b/src/Storages/FileLog/FileLogSource.cpp
index 0c266178142..7beee42c99c 100644
--- a/src/Storages/FileLog/FileLogSource.cpp
+++ b/src/Storages/FileLog/FileLogSource.cpp
@@ -1,5 +1,3 @@
-#include <DataStreams/ConvertingBlockInputStream.h>
-#include <DataStreams/OneBlockInputStream.h>
 #include <Formats/FormatFactory.h>
 #include <Interpreters/Context.h>
 #include <Processors/Executors/StreamingFormatExecutor.h>
diff --git a/src/Storages/FileLog/StorageFileLog.cpp b/src/Storages/FileLog/StorageFileLog.cpp
index c9b29a5a9d1..a75c9b0190e 100644
--- a/src/Storages/FileLog/StorageFileLog.cpp
+++ b/src/Storages/FileLog/StorageFileLog.cpp
@@ -14,7 +14,6 @@
 #include <Parsers/ASTLiteral.h>
 #include <Processors/Executors/CompletedPipelineExecutor.h>
 #include <Processors/Pipe.h>
-#include <Processors/Transforms/ExpressionTransform.h>
 #include <Storages/FileLog/FileLogSource.h>
 #include <Storages/FileLog/ReadBufferFromFileLog.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).is_open())
-                (*file_ctx.reader).close();
+            if (file_ctx.reader->is_open())
+                file_ctx.reader->close();
         }
 
         auto & meta = findInMap(file_infos.meta_by_inode, file_ctx.inode);