thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-22 09:40:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Storage Kafka: Schema positional argument number

Browse Source 
I hereby agree to the terms of the CLA available at: https://yandex.ru/legal/cla/?lang=en
This commit is contained in:
Vojtech Splichal 2018-09-17 13:01:10 +02:00
parent 9148adb717
commit 5aca7f3c6e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Storages/Kafka/StorageKafka.cpp
View File

@ -727,7 +727,7 @@ void registerStorageKafka(StorageFactory & factory)
String schema;
if (args_count >= 6)
{
engine_args[5] = evaluateConstantExpressionOrIdentifierAsLiteral(engine_args[4], args.local_context);
engine_args[5] = evaluateConstantExpressionOrIdentifierAsLiteral(engine_args[5], args.local_context);
auto ast = typeid_cast<const ASTLiteral *>(engine_args[5].get());
if (ast && ast->value.getType() == Field::Types::String)