diff --git a/src/Storages/ExternalStream/StorageExternalStreamImpl.h b/src/Storages/ExternalStream/StorageExternalStreamImpl.h index eb7e0362947..35f35187f15 100644 --- a/src/Storages/ExternalStream/StorageExternalStreamImpl.h +++ b/src/Storages/ExternalStream/StorageExternalStreamImpl.h @@ -12,7 +12,12 @@ namespace DB class StorageExternalStreamImpl : public std::enable_shared_from_this { public: - explicit StorageExternalStreamImpl(std::unique_ptr settings_): settings(std::move(settings_)) {} + explicit StorageExternalStreamImpl(std::unique_ptr settings_): settings(std::move(settings_)) { + /// Make it easier for people to ingest data from external streams. A lot of times people didn't see data coming + /// only because the external stream does not have all the fields. + if (!settings->input_format_skip_unknown_fields.changed) + settings->input_format_skip_unknown_fields = true; + } virtual ~StorageExternalStreamImpl() = default; virtual void startup() = 0;