Господа можете наставить на путь истинный. Читаем топик с kafka

Question

Господа можете наставить на путь истинный. Читаем топик с kafka

через clikHouse'ный дживок kafka() с форматом CSV. И в какой-то рандомный момент вылезает ошибка:

2020.04.05 08:37:30.332182 [ 85 ] {} <Error> void DB::StorageKafka::threadFunc(): Code: 27, e.displayText() = DB::Exception: Cannot parse input: expected , at end of stream.: (at row 1)
, Stack trace (when copying this message, always include the lines below):

0. Poco::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int) @ 0x1050f0d0 in /usr/bin/clickhouse
1. DB::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int) @ 0x8f3272d in /usr/bin/clickhouse
2. ? @ 0x8f6b753 in /usr/bin/clickhouse
3. ? @ 0xdc27b5d in /usr/bin/clickhouse
4. DB::CSVRowInputFormat::readRow(std::__1::vector<COW<DB::IColumn>::mutable_ptr<DB::IColumn>, std::__1::allocator<COW<DB::IColumn>::mutable_ptr<DB::IColumn> > >&, DB::RowReadExtension&) @ 0xdc2db29 in /usr/bin/clickhouse
5. DB::IRowInputFormat::generate() @ 0xdbfb9c1 in /usr/bin/clickhouse
6. DB::ISource::work() @ 0xdb79f5b in /usr/bin/clickhouse
7. ? @ 0xd83de4d in /usr/bin/clickhouse
8. DB::KafkaBlockInputStream::readImpl() @ 0xd83ea83 in /usr/bin/clickhouse
9. DB::IBlockInputStream::read() @ 0xce2f36f in /usr/bin/clickhouse
10. DB::copyData(DB::IBlockInputStream&, DB::IBlockOutputStream&, std::__1::atomic<bool>*) @ 0xce6df8f in /usr/bin/clickhouse
11. DB::StorageKafka::streamToViews() @ 0xd829ee8 in /usr/bin/clickhouse
12. DB::StorageKafka::threadFunc() @ 0xd82a800 in /usr/bin/clickhouse
13. DB::BackgroundSchedulePoolTaskInfo::execute() @ 0xcfe5815 in /usr/bin/clickhouse
14. DB::BackgroundSchedulePool::threadFunction() @ 0xcfe5e32 in /usr/bin/clickhouse
15. ? @ 0xcfe5f70 in /usr/bin/clickhouse
16. ThreadPoolImpl<std::__1::thread>::worker(std::__1::__list_iterator<std::__1::thread, void*>) @ 0x8f567eb in /usr/bin/clickhouse
17. ? @ 0x8f54c33 in /usr/bin/clickhouse
18. start_thread @ 0x76db in /lib/x86_64-linux-gnu/libpthread-2.27.so
19. __clone @ 0x12188f in /lib/x86_64-linux-gnu/libc-2.27.so
(version 20.3.5.21 (official build))

#backend #clickhouse #database #devops #programming #russian

0

06.04.2020

1 ответов

18 просмотров

Yurii · Accepted Answer

Yurii

попробуй добовать в настройки таблицы kafka_row_delimiter = '\n'

0

06.04.2020

184 похожих чатов

Господа можете наставить на путь истинный. Читаем топик с kafka

1 ответов

Похожие вопросы