при загрузке в кафка таблицу? С чем это может быть связано?
какой формат сообщения? покажите параметры создания Kafka таблицы?
ENGINE = Kafka SETTINGS kafka_broker_list = 'hadoop_brohers', kafka_topic_list = 'topic_name', kafka_format = 'JSONEachRow', kafka_group_name = 'name'
хм. а нет каких нибудь типов данных типа 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
есть lowcardinality, словарь
а со стороны kafka никаких ошибок нет? (я правда не знаю где смотреть) isQueryCancelled просто так не возникает...
ну эээ.... то есть вы хотите вставить в кафку которой нет? ;) или что именно кильнули? работающий INSERT запрос?
почему это нет? кафка таблица есть
ну наличие engine=Kafka таблицы не говорит о том что kafka работает это просто способ запустить некоторый фоновый thread который будет разгребать топик при чтении и записывать в топик при старте
Обсуждают сегодня