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

Всем привет! А кто-нибудь сталкивался с ошибкой 32 ATTEMPT_TO_READ_AFTER_EOF

при загрузке в кафка таблицу? С чем это может быть связано?

10 ответов

46 просмотров

какой формат сообщения? покажите параметры создания Kafka таблицы?

Олес-Vasina Автор вопроса
Slach [altinity]
какой формат сообщения? покажите параметры создани...

ENGINE = Kafka SETTINGS kafka_broker_list = 'hadoop_brohers', kafka_topic_list = 'topic_name', kafka_format = 'JSONEachRow', kafka_group_name = 'name'

Олес Vasina
ENGINE = Kafka SETTINGS kafka_broker_list = 'hadoo...

хм. а нет каких нибудь типов данных типа Decimal ? вообще было бы не плохо весь стектрейс ошибки увидеть

Олес-Vasina Автор вопроса
Slach [altinity]
хм. а нет каких нибудь типов данных типа Decimal ?...

exception_code: 32 exception: Code: 32, e.displayText() = DB::Exception: Attempt to read after eof (version 20.8.13.15 (official build)) stack_trace: 0. Poco::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int) @ 0x18cd37c0 in /usr/bin/clickhouse 1. DB::throwReadAfterEOF() @ 0xe6397d1 in /usr/bin/clickhouse 2. DB::readVarUInt(unsigned long&, DB::ReadBuffer&) @ 0xe834ab4 in /usr/bin/clickhouse 3. DB::TCPHandler::isQueryCancelled() @ 0x1639c46a in /usr/bin/clickhouse 4. DB::TCPHandler::processOrdinaryQueryWithProcessors() @ 0x1639e3d2 in /usr/bin/clickhouse 5. DB::TCPHandler::runImpl() @ 0x163a277d in /usr/bin/clickhouse 6. DB::TCPHandler::run() @ 0x163a3420 in /usr/bin/clickhouse 7. Poco::Net::TCPServerConnection::start() @ 0x18bf177b in /usr/bin/clickhouse 8. Poco::Net::TCPServerDispatcher::run() @ 0x18bf1e98 in /usr/bin/clickhouse 9. Poco::PooledThread::run() @ 0x18d705a6 in /usr/bin/clickhouse 10. Poco::ThreadImpl::runnableEntry(void*) @ 0x18d6b9a0 in /usr/bin/clickhouse 11. start_thread @ 0x7fa3 in /usr/lib/x86_64-linux-gnu/libpthread-2.28.so 12. clone @ 0xf94cf in /usr/lib/x86_64-linux-gnu/libc-2.28.so

Олес-Vasina Автор вопроса
Олес Vasina
exception_code: 32 exception: Cod...

есть lowcardinality, словарь

Олес Vasina
есть lowcardinality, словарь

а со стороны kafka никаких ошибок нет? (я правда не знаю где смотреть) isQueryCancelled просто так не возникает...

Олес Vasina
ну ее кильнули

ну эээ.... то есть вы хотите вставить в кафку которой нет? ;) или что именно кильнули? работающий INSERT запрос?

Олес-Vasina Автор вопроса
Олес Vasina
почему это нет? кафка таблица есть

ну наличие engine=Kafka таблицы не говорит о том что kafka работает это просто способ запустить некоторый фоновый thread который будет разгребать топик при чтении и записывать в топик при старте

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

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

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта