DC
т.е. какбы как kafka Engine создана? Что в логе КХ? КХ вообще достукивается до брокера?
Size: a a a
2020 September 21
НБ
а почему вы думаете что в localization_history_queue что-то пишется? Как вы это определили?
Делаю селекты и оно возвращает результат, а следовательно какие-то данные приходят. Да я вкурсе что после считывания данные иссчезают
DC
Делаю селекты и оно возвращает результат, а следовательно какие-то данные приходят. Да я вкурсе что после считывания данные иссчезают
OK а покажите desc localization_history и desc localization_history localization_history_queue
toDateTime(substr(toString(timestamp), 1, 10)) AS timestamp, <--- parseDateTimeBestEffort
toDateTime(substr(toString(timestamp), 1, 10)) AS timestamp, <--- parseDateTimeBestEffort
НБ
desc localization_history
user_id,String,"",""
timestamp,DateTime,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
sign,Int8,DEFAULT,1
desc localization_history_queue
user_id,String,"",""
timestamp,Int64,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
user_id,String,"",""
timestamp,DateTime,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
sign,Int8,DEFAULT,1
desc localization_history_queue
user_id,String,"",""
timestamp,Int64,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
DC
desc localization_history
user_id,String,"",""
timestamp,DateTime,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
sign,Int8,DEFAULT,1
desc localization_history_queue
user_id,String,"",""
timestamp,Int64,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
user_id,String,"",""
timestamp,DateTime,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
sign,Int8,DEFAULT,1
desc localization_history_queue
user_id,String,"",""
timestamp,Int64,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
timestamp,Int64,"",""
select toDateTime(substr(toString(20200101000000), 1, 10))
2034-01-04 17:55:00
select toDateTime(substr(toString(20200101000000), 1, 10))
2034-01-04 17:55:00
DC
SELECT parseDateTimeBestEffort(toString(20200101000000))
┌─parseDateTimeBestEffort(toString(20200101000000))─┐
│ 2020-01-01 00:00:00 │
└───────────────────────────────────────────────────┘
DC
desc localization_history
user_id,String,"",""
timestamp,DateTime,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
sign,Int8,DEFAULT,1
desc localization_history_queue
user_id,String,"",""
timestamp,Int64,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
user_id,String,"",""
timestamp,DateTime,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
sign,Int8,DEFAULT,1
desc localization_history_queue
user_id,String,"",""
timestamp,Int64,"",""
group_id,String,"",""
latitude,Float32,"",""
longitude,Float32,"",""
state,String,"",""
place_id,String,"",""
accuracy,Float32,"",""
зависит от версии КХ, в старых КХ sign,Int8,DEFAULT,1 такое не работало и выдавало ошибку что поле sign нет в SELECT
надо смотреть лог КХ , скорее всего там куча ругани, и понятно все из ошибок
надо смотреть лог КХ , скорее всего там куча ругани, и понятно все из ошибок
НБ
Спасибо за советы, завтра поковыряю что да как
2020 September 22
ВГ
Всем привет) А это нормальное поведение?
ВГ
Как я понимаю, проблема в том, как round определяет тип первого аргумента
ВГ
Так же натолкнулся на багу при использовании divide с decimal - divide для всех типов при делении на ноль возвращает inf, но если второй аргумент decimal - бросает исключение(как intDiv)
ВГ
ClickHouse server version 19.13.1 revision 54425
MG
я бы насчет деления несогласился
ВГ
Почему?
MG
децимал это интеджер всетаки там деление с остатком
MG
а когда флот делишь то бесконечность это норм - в целых нет бесконечности
ВГ
В документации отдельно описаны функции с разным ожидаемым поведением при делении на ноль, и дефолтная divide не должна бросать исключение.