try fix batch async insert settings for Distributed

This commit is contained in:
tai 2019-04-29 14:50:06 +08:00
parent 0d39968233
commit b394a79af3

View File

@ -463,8 +463,7 @@ void StorageDistributedDirectoryMonitor::processFilesWithBatching(const std::map
{
/// Determine metadata of the current file and check if it is not broken.
ReadBufferFromFile in{file_path};
insert_settings.deserialize(in);
readStringBinary(insert_query, in);
readQueryAndSettings(in, insert_settings, insert_query);
CompressedReadBuffer decompressing_in(in);
NativeBlockInputStream block_in(decompressing_in, ClickHouseRevision::get());