стоит kafka_skip_broken_messages = 1. Очередь стоит, не подскажите как пропустить битую запись?
(version 19.8.3.8)
2019.07.17 06:04:58.771450 [ 36 ] {} <Error> void DB::StorageKafka::streamThread(): Code: 27, e.displayText() = DB::Exception: Cannot parse input: expected " before: -02-12","ip":"197.234.221.157","model":"vision u22","os_version":"6.0","sdk":"2.4.10","package_version":"1.0","connection":"MOBILE_UNKNOWN","kind":"PHONE","loca: (while read the value of key first_request_date): (Already have 2 errors out of 60223 rows, which is 0.000033209904 of all rows): (at row 60223)
, Stack trace:
0. /usr/bin/clickhouse-server(StackTrace::StackTrace()+0x16) [0x78e07d6]
1. /usr/bin/clickhouse-server(DB::Exception::Exception(std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, int)+0x22) [0x3a0d472]
2. /usr/bin/clickhouse-server(DB::throwAtAssertionFailed(char const*, DB::ReadBuffer&)+0x138) [0x7907ee8]
3. /usr/bin/clickhouse-server(DB::DataTypeDate::deserializeTextJSON(DB::IColumn&, DB::ReadBuffer&, DB::FormatSettings const&) const+0x2d4) [0x6c1f014]
4. /usr/bin/clickhouse-server(DB::JSONEachRowRowInputStream::readField(unsigned long, std::vector<COW<DB::IColumn>::mutable_ptr<DB::IColumn>, std::allocator<COW<DB::IColumn>::mutable_ptr<DB::IColumn> > >&)+0x65) [0x70eab45]
5. /usr/bin/clickhouse-server(DB::JSONEachRowRowInputStream::readJSONObject(std::vector<COW<DB::IColumn>::mutable_ptr<DB::IColumn>, std::allocator<COW<DB::IColumn>::mutable_ptr<DB::IColumn> > >&)+0x484) [0x70eb074]
6. /usr/bin/clickhouse-server(DB::JSONEachRowRowInputStream::read(std::vector<COW<DB::IColumn>::mutable_ptr<DB::IColumn>, std::allocator<COW<DB::IColumn>::mutable_ptr<DB::IColumn> > >&, DB::RowReadExtension&)+0x13d) [0x70ebfad]
7. /usr/bin/clickhouse-server(DB::BlockInputStreamFromRowInputStream::readImpl()+0x168) [0x73d26d8]
8. /usr/bin/clickhouse-server(DB::IBlockInputStream::read()+0x188) [0x6bec8c8]
9. /usr/bin/clickhouse-server(DB::KafkaBlockInputStream::readImpl()+0x28) [0x78be068]
10. /usr/bin/clickhouse-server(DB::IBlockInputStream::read()+0x188) [0x6bec8c8]
11. /usr/bin/clickhouse-server(DB::copyData(DB::IBlockInputStream&, DB::IBlockOutputStream&, std::atomic<bool>*)+0x6b) [0x6c0ae0b]
12. /usr/bin/clickhouse-server(DB::StorageKafka::streamToViews()+0x5cd) [0x78b816d]
13. /usr/bin/clickhouse-server(DB::StorageKafka::streamThread()+0x1ba) [0x78b86ba]
14. /usr/bin/clickhouse-server(DB::BackgroundSchedulePoolTaskInfo::execute()+0xfa) [0x6b945aa]
15. /usr/bin/clickhouse-server(DB::BackgroundSchedulePool::threadFunction()+0x6a) [0x6b94c8a]
16. /usr/bin/clickhouse-server() [0x6b94d09]
17. /usr/bin/clickhouse-server(ThreadPoolImpl<std::thread>::worker(std::_List_iterator<std::thread>)+0x1af) [0x78e6a0f]
18. /usr/bin/clickhouse-server() [0xb79aaef]
19. /lib/x86_64-linux-gnu/libpthread.so.0(+0x76ba) [0x7fd55e6836ba]
20. /lib/x86_64-linux-gnu/libc.so.6(clone+0x6d) [0x7fd55dca441d]
(version 19.8.3.8 (official build))
kafka_skip_broken_messages = 1 Already have 2 errors out of 60223 rows, which is 0.000033209904 of all rows): (at row 60223)
Обсуждают сегодня