Created
May 5, 2022 00:47
-
-
Save cra/d4292792fc76c54d38c1f32a85b03131 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2022.05.05 00:47:02.330955 [ 261 ] {} <Trace> StorageKafka (lab4_kafka_queue): Polled batch of 599 messages. Offsets position: [ andrey_bratukhin_lab03_in[0:37533] ] | |
2022.05.05 00:47:02.331745 [ 261 ] {} <Trace> StorageKafka (lab4_kafka_queue): Re-joining claimed consumer after failure | |
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. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment