Merge pull request #15 from bigo-sg/bigo-22.5.1.2079-liang

fix bugs
bigo-sg · Jul 1, 2022 · 7d9186c · 7d9186c
2 parents 75fdb8f + fa6a6c7
commit 7d9186c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/src/Storages/Hive/StorageHiveCluster.cpp b/src/Storages/Hive/StorageHiveCluster.cpp
@@ -240,8 +240,8 @@ ASTPtr StorageHiveCluster::rewriteQuery(const ASTPtr & query)
         struct_buf << name_and_type.name << " " << name_and_type.type->getName();
         i++;
     }
-    auto hash_table_structure = std::make_shared<ASTLiteral>(struct_buf.str());
-    table_func->arguments->children.push_back(hash_table_structure);
+    auto table_structure = std::make_shared<ASTLiteral>(struct_buf.str());
+    table_func->arguments->children.push_back(table_structure);
 
     auto partition_key = std::make_shared<ASTLiteral>(queryToString(partition_by_ast));
     table_func->arguments->children.push_back(partition_key);
@@ -291,7 +291,8 @@ void registerStorageHiveCluster(StorageFactory & factory_)
                 args.comment,
                 partition_by->ptr(),
                 std::move(hive_settings),
-                args.getContext());
+                args.getContext(),
+                true);
         },
         StorageFactory::StorageFeatures{
             .supports_settings = true,

diff --git a/src/Storages/Hive/StorageHiveCluster.h b/src/Storages/Hive/StorageHiveCluster.h
@@ -84,7 +84,7 @@ class StorageHiveCluster : public IStorage, WithContext
 
     Poco::Logger * logger = &Poco::Logger::get("StorageHiveCluster");
 
-    ASTPtr rewriteQuery(const ASTPtr & original_query);
+    ASTPtr rewriteQuery(const ASTPtr & query);
 };
 }