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

Добрый день, появилась ошибка при парсинге сообщений из кафки, хотя

стоит 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))

1 ответов

7 просмотров

kafka_skip_broken_messages = 1 Already have 2 errors out of 60223 rows, which is 0.000033209904 of all rows): (at row 60223)

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

Обсуждают сегодня

А как старый хаскел с новым стыковать ? потому как тут работает https://play.haskell.org/saved/C3xpMzcd, а вот тут https://stepik.org/lesson/7602/step/9?unit=1473 нет ошибка C...
Fedor
131
И из-за этого сужается карман. Нет свободного полёта. Они либо могут какой-то заточенный прикладной софт, либо какой-то простой системный написать. По шаблону. А, допустим, по...
КТ315
9
Всем привет! Подскажите, как решить проблему или из-за чего это происходит. У меня есть проблема в WebStorm (v.2024.1.3): я ставлю любую тему, и через какое-то время меняется ...
Alexander Sheigov
12
всем вопрос. есть функция, которая иногда в линуксе валится с исключением EConvertError Invalid argument to date encode на строке Result:=LocalToUtcDateTime(FileDateToDateTime...
Handatros
6
А с каким компилятором не будет ошибкой использовать асм вставки?
Replicant ~
14
Подскажите пожалуйста, как все-таки правильно указывать реф на чарт-зависимость? Имеется сервис service1. Бандл с ним опубликован в Harbor: infra-harbor.xxx.lan/library/dev/yy...
Alexander Kozharsky
1
Вопрос я правильно понимаю что в коде newtype ArrowMap k v = ArrowMap { getArrowMap :: k -> Maybe v } getArrowMap есть функция типа k -> Maybe v, если да, то не понимаю задач...
Fedor
64
что насчет пагинга? на осдеве непонятно(
Vi Chapmann 🪙
26
Народ, кто шарит в расширенных разделах (EBR/EPR) на дисках с разметками MBR? Везде пишут (в вики рус/англ) в частности + другие источники смотрел, что первый сектор расширенн...
Eugene Krasnikov (ᴊɪɴ x)
1
Как Вы считаете нормально ли в двадцатых годах 21 века в ВУЗах Российской Федерации обучать студентов работе с TASM? Не слишком ли это "архаично"? (Если оффтоп или флейм для э...
Spiker01
52
Карта сайта