add more holders

This commit is contained in:
Alexander Tokmakov 2020-10-16 20:16:58 +03:00
parent 1003de75ed
commit c19d2efd88
3 changed files with 3 additions and 0 deletions

View File

@ -239,6 +239,7 @@ Pipe StorageBuffer::read(
}
pipe_from_dst.addTableLock(destination_lock);
pipe_from_dst.addStorageHolder(destination);
}
Pipe pipe_from_buffers;

View File

@ -82,6 +82,7 @@ Pipe StorageMaterializeMySQL::read(
}
Pipe pipe = nested_storage->read(require_columns_name, nested_metadata, query_info, context, processed_stage, max_block_size, num_streams);
pipe.addTableLock(lock);
if (!expressions->children.empty() && !pipe.empty())
{

View File

@ -357,6 +357,7 @@ Pipe StorageMerge::createSources(
convertingSourceStream(header, metadata_snapshot, *modified_context, modified_query_info.query, pipe, processed_stage);
pipe.addTableLock(struct_lock);
pipe.addStorageHolder(storage);
pipe.addInterpreterContext(modified_context);
}