This commit is contained in:
feng lv 2021-07-11 06:18:03 +00:00
parent 85aa71c377
commit 8dbb2a3ed9
4 changed files with 4 additions and 5 deletions

View File

@ -4,6 +4,7 @@
#include <Poco/Foundation.h>
#include <Poco/Path.h>
#include <memory>
#include <mutex>
class FileLogDirectoryWatcher

View File

@ -14,7 +14,6 @@ namespace DB
namespace ErrorCodes
{
extern const int CANNOT_COMMIT_OFFSET;
}
ReadBufferFromFileLog::ReadBufferFromFileLog(

View File

@ -25,7 +25,7 @@ public:
~ReadBufferFromFileLog() override = default;
void open();
void close();
void close();
auto pollTimeout() const { return poll_timeout; }

View File

@ -38,9 +38,7 @@ namespace DB
namespace ErrorCodes
{
extern const int NOT_IMPLEMENTED;
extern const int LOGICAL_ERROR;
extern const int BAD_ARGUMENTS;
extern const int NUMBER_OF_ARGUMENTS_DOESNT_MATCH;
}
@ -270,7 +268,8 @@ void registerStorageFileLog(StorageFactory & factory)
size_t args_count = engine_args.size();
if (args_count != 2)
throw Exception("Arguments size of StorageFileLog should be 2, path and format name", ErrorCodes::BAD_ARGUMENTS);
throw Exception(
"Arguments size of StorageFileLog should be 2, path and format name", ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
auto path_ast = evaluateConstantExpressionAsLiteral(engine_args[0], args.getContext());
auto format_ast = evaluateConstantExpressionAsLiteral(engine_args[1], args.getContext());