gistfile1.txt

2022.05.05 00:47:02.332298 [ 261 ] {} <Error> void DB::StorageKafka::threadFunc(size_t): Code: 33. DB::ParsingException: Unexpected end of stream while parsing JSONEachRow format: while parsing Kafka message (topic: andrey_bratukhin_lab03_in, partition: 0, offset: 36934)': While executing Kafka: (at row 2)
. (CANNOT_READ_ALL_DATA), Stack trace (when copying this message, always include the lines below):

0. DB::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int, bool) @ 0xa82d07a in /usr/bin/clickhouse
1. DB::JSONEachRowRowInputFormat::advanceToNextKey(unsigned long) @ 0x14904954 in /usr/bin/clickhouse
2. DB::JSONEachRowRowInputFormat::readJSONObject(std::__1::vector<COW<DB::IColumn>::mutable_ptr<DB::IColumn>, std::__1::allocator<COW<DB::IColumn>::mutable_ptr<DB::IColumn> > >&) @ 0x149043e1 in /usr/bin/clickhouse
3. DB::JSONEachRowRowInputFormat::readRow(std::__1::vector<COW<DB::IColumn>::mutable_ptr<DB::IColumn>, std::__1::allocator<COW<DB::IColumn>::mutable_ptr<DB::IColumn> > >&, DB::RowReadExtension&) @ 0x14905556 in /usr/bin/clickhouse
4. DB::IRowInputFormat::generate() @ 0x148add10 in /usr/bin/clickhouse
5. DB::ISource::tryGenerate() @ 0x148414b5 in /usr/bin/clickhouse
6. DB::ISource::work() @ 0x1484107a in /usr/bin/clickhouse
7. DB::StreamingFormatExecutor::execute() @ 0x14869da2 in /usr/bin/clickhouse
8. DB::KafkaSource::generateImpl() @ 0x1332f24f in /usr/bin/clickhouse
9. DB::KafkaSource::generate() @ 0x133318cf in /usr/bin/clickhouse
10. DB::ISource::tryGenerate() @ 0x148414b5 in /usr/bin/clickhouse
11. DB::ISource::work() @ 0x1484107a in /usr/bin/clickhouse
12. DB::SourceWithProgress::work() @ 0x14a8c662 in /usr/bin/clickhouse
13. DB::ExecutionThreadContext::executeTask() @ 0x14860b23 in /usr/bin/clickhouse
14. DB::PipelineExecutor::executeStepImpl(unsigned long, std::__1::atomic<bool>*) @ 0x1485539e in /usr/bin/clickhouse
15. DB::PipelineExecutor::executeImpl(unsigned long) @ 0x148541e9 in /usr/bin/clickhouse
16. DB::PipelineExecutor::execute(unsigned long) @ 0x14853ef8 in /usr/bin/clickhouse
17. DB::CompletedPipelineExecutor::execute() @ 0x14852924 in /usr/bin/clickhouse
18. DB::StorageKafka::streamToViews() @ 0x13324eda in /usr/bin/clickhouse
19. DB::StorageKafka::threadFunc(unsigned long) @ 0x13322e18 in /usr/bin/clickhouse
20. DB::BackgroundSchedulePoolTaskInfo::execute() @ 0x12f8470e in /usr/bin/clickhouse
21. DB::BackgroundSchedulePool::threadFunction() @ 0x12f870a7 in /usr/bin/clickhouse
22. ? @ 0x12f88170 in /usr/bin/clickhouse
23. ThreadPoolImpl<std::__1::thread>::worker(std::__1::__list_iterator<std::__1::thread, void*>) @ 0xa86f4b7 in /usr/bin/clickhouse
24. ? @ 0xa872ebd in /usr/bin/clickhouse
25. ? @ 0x7fc615397609 in ?
26. __clone @ 0x7fc6152be293 in ?
 (version 22.1.3.7 (official build))
2022.05.05 00:47:02.332465 [ 261 ] {} <Trace> StorageKafka (lab4_kafka_queue): Execution took 504 ms.