diff --git a/dbms/src/Interpreters/InterpreterCreateQuery.cpp b/dbms/src/Interpreters/InterpreterCreateQuery.cpp
index 87bec3e6d3d..ec79af18604 100644
--- a/dbms/src/Interpreters/InterpreterCreateQuery.cpp
+++ b/dbms/src/Interpreters/InterpreterCreateQuery.cpp
@@ -531,6 +531,7 @@ std::unique_ptr<DDLGuard> tryGetDDLGuard(
                     "Table " + database_name + "." + table_name + " already exists.",
                     ErrorCodes::TABLE_ALREADY_EXISTS);
         }
+        return guard;
     }
     catch (Exception & e)
     {
diff --git a/dbms/src/Interpreters/InterpreterCreateQuery.h b/dbms/src/Interpreters/InterpreterCreateQuery.h
index 5114155a881..d15e5887519 100644
--- a/dbms/src/Interpreters/InterpreterCreateQuery.h
+++ b/dbms/src/Interpreters/InterpreterCreateQuery.h
@@ -34,7 +34,7 @@ using StoragePtr = std::shared_ptr<IStorage>;
 class InterpreterCreateQuery : public IInterpreter
 {
 public:
-    InterpreterCreateQuery(const ASTPtr & query_ptr_, Context & context_, std::string_view log_suffix_="");
+    InterpreterCreateQuery(const ASTPtr & query_ptr_, Context & context_, std::string_view log_suffix_ = "");
 
     BlockIO execute() override;