rename new method

This commit is contained in:
Alexander Tokmakov 2023-08-28 16:01:00 +02:00
parent 9ab545e28c
commit d41eca1dcc
3 changed files with 3 additions and 3 deletions

View File

@ -186,7 +186,7 @@ void DistributedAsyncInsertDirectoryQueue::shutdownAndDropAllData()
fs::remove_all(path);
}
void DistributedAsyncInsertDirectoryQueue::shutdown()
void DistributedAsyncInsertDirectoryQueue::shutdownWithoutFlush()
{
/// It's incompatible with should_batch_inserts
/// because processFilesWithBatching may push to the queue after shutdown

View File

@ -66,7 +66,7 @@ public:
void shutdownAndDropAllData();
void shutdown();
void shutdownWithoutFlush();
static std::shared_ptr<ISource> createSourceFromFile(const String & file_name);

View File

@ -1476,7 +1476,7 @@ void StorageDistributed::flushClusterNodesAllData(ContextPtr local_context)
if (need_flush)
node->flushAllData();
else
node->shutdown();
node->shutdownWithoutFlush();
}
}