Merge pull request #37224 from Vxider/wv-fix-dependency

Fix addDependency in WindowView
This commit is contained in:
Kseniia Sumarokova 2022-05-19 13:51:11 +02:00 committed by GitHub
commit b0c7cf910a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -1119,7 +1119,6 @@ StorageWindowView::StorageWindowView(
select_table_name = "one";
}
select_table_id = StorageID(select_database_name, select_table_name);
DatabaseCatalog::instance().addDependency(select_table_id, table_id_);
/// Extract all info from query; substitute Function_tumble and Function_hop with Function_windowID.
auto inner_query = innerQueryParser(select_query->as<ASTSelectQuery &>());
@ -1474,6 +1473,8 @@ void StorageWindowView::writeIntoWindowView(
void StorageWindowView::startup()
{
DatabaseCatalog::instance().addDependency(select_table_id, getStorageID());
// Start the working thread
clean_cache_task->activateAndSchedule();
fire_task->activateAndSchedule();