diff --git a/src/Storages/ExternalStream/StorageExternalStream.cpp b/src/Storages/ExternalStream/StorageExternalStream.cpp index 4b968ade3b2..862497be638 100644 --- a/src/Storages/ExternalStream/StorageExternalStream.cpp +++ b/src/Storages/ExternalStream/StorageExternalStream.cpp @@ -142,11 +142,13 @@ StorageExternalStream::StorageExternalStream( ContextPtr context_, const ColumnsDescription & columns_, std::unique_ptr external_stream_settings_, + const String & comment, bool attach) : IStorage(table_id_), WithContext(context_->getGlobalContext()) { StorageInMemoryMetadata storage_metadata; storage_metadata.setColumns(columns_); + storage_metadata.setComment(comment); setInMemoryMetadata(storage_metadata); auto stream = createExternalStream(this, std::move(external_stream_settings_), context_, engine_args, attach, std::make_shared(), std::move(context_)); @@ -167,7 +169,7 @@ void registerStorageExternalStream(StorageFactory & factory) external_stream_settings->loadFromQuery(*args.storage_def); return StorageExternalStream::create( - args.engine_args, args.table_id, args.getContext(), args.columns, std::move(external_stream_settings), args.attach); + args.engine_args, args.table_id, args.getContext(), args.columns, std::move(external_stream_settings), args.comment, args.attach); } else throw Exception(ErrorCodes::BAD_ARGUMENTS, "External stream requires correct settings setup"); diff --git a/src/Storages/ExternalStream/StorageExternalStream.h b/src/Storages/ExternalStream/StorageExternalStream.h index 538e7d8942d..59b1d989029 100644 --- a/src/Storages/ExternalStream/StorageExternalStream.h +++ b/src/Storages/ExternalStream/StorageExternalStream.h @@ -60,6 +60,7 @@ class StorageExternalStream final : public shared_ptr_helper external_stream_settings_, + const String & comment, bool attach); private: