From 5aca7f3c6ea33097eb6869fa53c5c790aad30a98 Mon Sep 17 00:00:00 2001 From: Vojtech Splichal Date: Mon, 17 Sep 2018 13:01:10 +0200 Subject: [PATCH] Fix Storage Kafka: Schema positional argument number I hereby agree to the terms of the CLA available at: https://yandex.ru/legal/cla/?lang=en --- dbms/src/Storages/Kafka/StorageKafka.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbms/src/Storages/Kafka/StorageKafka.cpp b/dbms/src/Storages/Kafka/StorageKafka.cpp index 73d4320616a..ed18e03df7f 100644 --- a/dbms/src/Storages/Kafka/StorageKafka.cpp +++ b/dbms/src/Storages/Kafka/StorageKafka.cpp @@ -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(engine_args[5].get()); if (ast && ast->value.getType() == Field::Types::String)