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

Use storage.uncommited_state

Browse Source
This commit is contained in:
Konstantin Bogdanov 2023-04-21 15:18:39 +02:00
parent 7e151428ac
commit 203276dfcc
Signed by: thevar1able
GPG Key ID: DB399448D9FE52F1
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Coordination/KeeperStorage.cpp
View File

@ -918,12 +918,14 @@ struct KeeperStorageCreateRequestProcessor final : public KeeperStorageRequestPr
std::vector<KeeperStorage::Delta> new_deltas;
if (zk_request->getOpNum() == Coordination::OpNum::CreateIfNotExists) {
auto & container = storage.container;
auto node_it = container.find(request.path);
if (node_it != container.end())
{
// auto & container = storage.container;
// auto node_it = container.find(request.path);
// if (node_it != container.end())
// {
// return new_deltas;
// }
if (storage.uncommitted_state.getNode(request.path) != nullptr)
return new_deltas;
}
}
auto parent_path = parentPath(request.path);