Skip to content

Commit d2c1a7f

Browse files
committed
force ddl entry lookup
1 parent cb8e0e6 commit d2c1a7f

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

src/Databases/DatabaseReplicatedWorker.cpp

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -468,13 +468,7 @@ DDLTaskPtr DatabaseReplicatedDDLWorker::initAndCheckTask(const String & entry_na
468468
return {};
469469
}
470470

471-
String node_data;
472-
if (!zookeeper->tryGet(entry_path, node_data))
473-
{
474-
LOG_ERROR(log, "Cannot get log entry {}", entry_path);
475-
throw Exception(ErrorCodes::LOGICAL_ERROR, "should be unreachable");
476-
}
477-
471+
String node_data = zookeeper->get(entry_path);
478472
task->entry.parse(node_data);
479473

480474
if (task->entry.query.empty())

0 commit comments

Comments
 (0)