Запросы одинаковым образом используют индекс. Но сравнение date с константной проще, чем вычисление месяца.

логично. Еще раз спасибо!:)

Подскажите, пожалуйста, по коду: вот у меня есть Block полученный от сервера, как мне его проще всего нарезать на строчки типа char**. Парсить то, что было на входе WriteBuffer?

По поводу, почему данные могут занимать меньше в ORC формате. Это может зависить от настроек сжатия. Если при использовании ORC, сжатие более сильное, чем lz4 - займёт меньше. Чтобы включить в ClickHouse более сильное сжатие, можно поменять настройку compression в config,xml, например, так: <compression> <case> <method>zstd</method> </case> </compression> - включит сжатие zstd при всех фоновых мержах.

Алексей, спасибо! Качество компрессии выросло в 2 раза!

Подскажите по session_id ( хочу в драйвере прикрутить ) и TEMPORARY TABLE - Эти таблицы можно удалить через DROP TABLE ? У меня не получается - посылаю запрос на CREATE , потом на DROP с указанием session_id - ошибка - Из доки : "- временные таблицы исчезают после завершения сессии; в том числе, при обрыве соединения" - получается нельзя использовать несколько соединений подряд с одним session_id , нужно постоянно держать connection ?

присоединяюсь к вопросу, т.к. при работе с нативным протоколом таже проблема, нет возможности удалять временные таблицы, а разрывать соединение каждый раз не очень удобно

Привет. Про LEFT JOIN. Может, кому пригодится. Вложенные запросы пришлось написать вместо просто таблиц, т.к. алиасы не работают так, как в MySQL. ✅ Так работает (вывожу регионы и страны с айдишниками): :) SELECT region_id, region_name, country_id, country_name FROM (SELECT region_id, name_ru as region_name, country_id FROM _regions_log WHERE 1=1 LIMIT 0,10) ANY LEFT JOIN (SELECT country_id, name_ru as country_name FROM _countries) USING(country_id) ORDER BY region_name LIMIT 0,10 SELECT region_id, region_name, country_id, country_name FROM ( SELECT region_id, name_ru AS region_name, country_id FROM _regions_log WHERE 1 = 1 LIMIT 0, 10 ) ANY LEFT JOIN ( SELECT country_id, name_ru AS country_name FROM _countries ) USING (country_id) ORDER BY region_name ASC LIMIT 0, 10 ┌─region_id─┬─region_name────────────┬─country_id─┬─country_name─┐ │ 2763 │ Chongqing Municipality │ 97 │ Китай │ │ 20573 │ Dornod Aymag │ 130 │ Монголия │ │ 875 │ Imo State │ 137 │ Нигерия │ │ 13330 │ Ogun State │ 137 │ Нигерия │ │ 2188 │ Pune │ 80 │ Индия │ │ 1000001 │ Адыгея │ 1 │ Россия │ │ 1000236 │ Архангельская область │ 1 │ Россия │ │ 1004118 │ Астраханская область │ 1 │ Россия │ │ 1004565 │ Башкортостан │ 1 │ Россия │ │ 1009404 │ Белгородская область │ 1 │ Россия │ └───────────┴────────────────────────┴────────────┴──────────────┘ 10 rows in set. Elapsed: 0.005 sec. Processed 3.96 thousand rows, 140.74 KB (756.70 thousand rows/s., 26.93 MB/s.) Кстати, звёздочка во внешнем селекте выводила только столбцы, соответствующие первому вложенному селекту. Перечисление всех - сработало.

А вот, с чего начал терять время на преобразования: ? Так - не работает (в отличие от MySQL): :) SELECT r.region_id as region_id, r.name_ru as region_name, r.country_id as country_id, c.name_ru as country_name FROM geodata._regions_log as r LEFT JOIN geodata._countries as c USING(country_id) WHERE 1=1 ORDER BY r.name_ru LIMIT 0,10 SELECT r.region_id AS region_id, r.name_ru AS region_name, r.country_id AS country_id, c.name_ru AS country_name FROM geodata._regions_log AS r LEFT JOIN geodata._countries AS c USING (country_id) WHERE 1 = 1 ORDER BY r.name_ru ASC LIMIT 0, 10 Received exception from server: Code: 60. DB::Exception: Received from localhost:9000, ::1. DB::Exception: Table geodata.geodata._countries doesn't exist.. 0 rows in set. Elapsed: 0.034 sec. ? Задвоенная БД? - убираем ваще. Но и так - не работает: :) SELECT r.region_id as region_id, r.name_ru as region_name, r.country_id as country_id, c.name_ru as country_name FROM _regions_log as r LEFT JOIN _countries as c USING(country_id) WHERE 1=1 ORDER BY r.name_ru LIMIT 0,10 SELECT r.region_id AS region_id, r.name_ru AS region_name, r.country_id AS country_id, c.name_ru AS country_name FROM _regions_log AS r LEFT JOIN _countries AS c USING (country_id) WHERE 1 = 1 ORDER BY r.name_ru ASC LIMIT 0, 10 Received exception from server: Code: 47. DB::Exception: Received from localhost:9000, ::1. DB::Exception: Unknown identifier: c.name_ru. 0 rows in set. Elapsed: 0.021 sec. Спасибо за внимание

Добрый день. Подскажите почему не рекомендуется хранить float в таблицах?

0.2 + 0.1 = 0.30000000000000004

вот поэтому

Спасибо

Добрый день. Обнаружил интересную особенность поведения внешних словарей CH 1.1.54245 Во всех конфигурационных файлах словарей прописаны значение параметра "Периодичность обновления для полностью загружаемых словарей": <lifetime> <min>3000</min> <max>4200</max> </lifetime> <layout> <hashed/> </layout> В основном конфиг файле config.xml СН параметр dictionaries_lazy_load не указан. Не могли бы подсказать почему внешние словари не обновляются в период, который указан в lifetime? А обновление всех словарей происходит только тогда, когда производится запрос к одному из словарей. Ошибок в логах нет. Словари висят в памяти определенное время, а потом удаляются. Заранее спасибо

Здравствуйте. Никто не сталкивался с проблемой на очень маленьких данных (10 мб) — очень большое число parts в partition и следовательно размер partition в несколько раз больше (60 мб) чем данных в ней. Используем granularity 512, но когда закачивали основной сет размером в 6 гб таких проблем не получали.

Подскажите по session_id ( хочу в драйвере прикрутить ) и TEMPORARY TABLE - Эти таблицы можно удалить через DROP TABLE ? У меня не получается - посылаю запрос на CREATE , потом на DROP с указанием session_id - ошибка - Из доки : "- временные таблицы исчезают после завершения сессии; в том числе, при обрыве соединения" - получается нельзя использовать несколько соединений подряд с одним session_id , нужно постоянно держать connection ?

Привет. В драйвер сми2 я прикрутил сессии простым добавлением в конфиг 'settings' => ['session_id' =>Helper::getUuid4()] Про обрыв соединения, скорее всего имели ввиду при подключении через родной клиент. При работе по http соединение держать не нужно.

Привет. Подскажите, как я могу сконкатенировать массивы?

Привет. В драйвер сми2 я прикрутил сессии простым добавлением в конфиг 'settings' => ['session_id' =>Helper::getUuid4()] Про обрыв соединения, скорее всего имели ввиду при подключении через родной клиент. При работе по http соединение держать не нужно.

Да я уже попробовал, сделал в dev $client->useSession() Но вот красиво и правильно unit test написать не получается )

Да я уже попробовал, сделал в dev $client->useSession() Но вот красиво и правильно unit test написать не получается )

TDD? :)

добрый день, вопрос актуален Alexandr Bocharov, [11.08.17 15:37] при прочих равных - SummingMergeTree vs AggregatingMergeTree у какого движка будет выше производительность, лучше потребление памяти, другие ньюансы/недостатки использования? может есть бенчмарки?

всем привет! папака /local/zookeeper/version-2 занимает 440Gb и в ней 15к файлов. Это нормально? Почистить можно ее?

Привет всем. Ребят а как яндекс реализует отправку батчем в метрики, там же клик это одно событие, где они хранят события перед отправкой?

может в RAM?

где-нибудь типа RabbitMQ?

Возможно ли использование поля из словаря в выражении WHERE? SELECT * FROM ( SELECT foo1, foo2, foo3, dictGetString('my_dict', 'dict_foo', tuple(toInt32(bar1), bar2)) FROM my_table WHERE date = '2017-05-11' ) AS t1 WHERE dict_foo != 'smth' LIMIT 10

у меня была идея либо в kafka, redis или просто RAM, но от мне интересно как это в яндексе устроенно

Привет всем. Ребят а как яндекс реализует отправку батчем в метрики, там же клик это одно событие, где они хранят события перед отправкой?

Движок buffer

Движок buffer

Напишу тесты тогда для проверки

Привет всем. Ребят а как яндекс реализует отправку батчем в метрики, там же клик это одно событие, где они хранят события перед отправкой?

На сколько я помню из рассказов о том как они кладут данные в метрике, то там был buffer в самом CH через которые эвенты сбрасываются в таблицу

Алексей не так давно рассказывал про то как этот буфер устроен и как им пользоваться. Плюсы и минусы. Если постараться, то можно в истории чатика найти )

всем привет! папака /local/zookeeper/version-2 занимает 440Gb и в ней 15к файлов. Это нормально? Почистить можно ее?

нашел, что A ZooKeeper server will not remove old snapshots and log files when using the default configuration. сколько посоветуете поставить autopurge.snapRetainCount и autopurge.purgeInterval? ну интервал часик например, а колво snapRetainCount?

TDD? :)

угу он самый

а блин, в доке же есть

спс =)

Привет. Подскажите, как я могу сконкатенировать массивы?

SELECT [1, 2] AS x, [3, 4] AS y, arrayReduce('groupArrayArray', [x, y]) AS xy ┌─x─────┬─y─────┬─xy────────┐ │ [1,2] │ [3,4] │ [1,2,3,4] │ └───────┴───────┴───────────┘

Спасибо, а можно ли как-то над каждым элементом одного массива произвести изменение по какой-то функции и получить на выходе масссив: Например, ['x', 'y'] -> ['xx', 'yy'] ?

https://clickhouse.yandex/docs/ru/single/index.html#arraymap-func-arr1

Спасибо, проглядел!

Добрый день. Обнаружил интересную особенность поведения внешних словарей CH 1.1.54245 Во всех конфигурационных файлах словарей прописаны значение параметра "Периодичность обновления для полностью загружаемых словарей": <lifetime> <min>3000</min> <max>4200</max> </lifetime> <layout> <hashed/> </layout> В основном конфиг файле config.xml СН параметр dictionaries_lazy_load не указан. Не могли бы подсказать почему внешние словари не обновляются в период, который указан в lifetime? А обновление всех словарей происходит только тогда, когда производится запрос к одному из словарей. Ошибок в логах нет. Словари висят в памяти определенное время, а потом удаляются. Заранее спасибо

Похожая проблема. Есть у кого то мысли???

Подскажите, пожалуйста, по коду: вот у меня есть Block полученный от сервера, как мне его проще всего нарезать на строчки типа char**. Парсить то, что было на входе WriteBuffer?

У столбцов (IColumn) есть метод getDataAt, который позволяет получить ссылку на кусок памяти, где расположено значение. Это работает только для простых типов. Например, для массивов уже нет. Также есть метод operator[], который позволяет получить значение в виде Field.

Подскажите по session_id ( хочу в драйвере прикрутить ) и TEMPORARY TABLE - Эти таблицы можно удалить через DROP TABLE ? У меня не получается - посылаю запрос на CREATE , потом на DROP с указанием session_id - ошибка - Из доки : "- временные таблицы исчезают после завершения сессии; в том числе, при обрыве соединения" - получается нельзя использовать несколько соединений подряд с одним session_id , нужно постоянно держать connection ?

И правда, временные таблицы не удаляются вообще никак. Странно, что только сейчас заметили.

А вот, с чего начал терять время на преобразования: ? Так - не работает (в отличие от MySQL): :) SELECT r.region_id as region_id, r.name_ru as region_name, r.country_id as country_id, c.name_ru as country_name FROM geodata._regions_log as r LEFT JOIN geodata._countries as c USING(country_id) WHERE 1=1 ORDER BY r.name_ru LIMIT 0,10 SELECT r.region_id AS region_id, r.name_ru AS region_name, r.country_id AS country_id, c.name_ru AS country_name FROM geodata._regions_log AS r LEFT JOIN geodata._countries AS c USING (country_id) WHERE 1 = 1 ORDER BY r.name_ru ASC LIMIT 0, 10 Received exception from server: Code: 60. DB::Exception: Received from localhost:9000, ::1. DB::Exception: Table geodata.geodata._countries doesn't exist.. 0 rows in set. Elapsed: 0.034 sec. ? Задвоенная БД? - убираем ваще. Но и так - не работает: :) SELECT r.region_id as region_id, r.name_ru as region_name, r.country_id as country_id, c.name_ru as country_name FROM _regions_log as r LEFT JOIN _countries as c USING(country_id) WHERE 1=1 ORDER BY r.name_ru LIMIT 0,10 SELECT r.region_id AS region_id, r.name_ru AS region_name, r.country_id AS country_id, c.name_ru AS country_name FROM _regions_log AS r LEFT JOIN _countries AS c USING (country_id) WHERE 1 = 1 ORDER BY r.name_ru ASC LIMIT 0, 10 Received exception from server: Code: 47. DB::Exception: Received from localhost:9000, ::1. DB::Exception: Unknown identifier: c.name_ru. 0 rows in set. Elapsed: 0.021 sec. Спасибо за внимание

Спасибо за примеры! Это старая проблема, нам давно пора это исправить. Постепенно делаем.

Подскажите пожалуйста, вижок AggregatingMergeTree как-то сокращает объем таблицы и или нет? Вообще какие могут быть области его применения? Спасибо

Добрый день. Подскажите почему не рекомендуется хранить float в таблицах?

Никаких особенных проблем с float-ами нет кроме того, что это именно float-ы - то есть, плохо подходят для денег и в тех местах, где нужно хранить десятичные дроби без потери точности. А если нужно обрабатывать данные мониторинга, физические рассчёты, то float-ы будут в самый раз.

/stat@combot

combot.org/chat/-1001080295593

И правда, временные таблицы не удаляются вообще никак. Странно, что только сейчас заметили.

Я для своих задач делаю через TinyLog, и потом удаляю - а озадачился только из за примера с session_id. Мне кажется мало кто использует ее в ручном режиме, как в доки и написанно - "В большинстве случаев, временные таблицы создаются не вручную"

@milovidov_an за исключением того, что они будут шуметь и фигово компрессироваться

@milovidov_an при том, что в большинстве случаев точность даже float для всего допустимого диапазона значений не особо нужна

Никаких особенных проблем с float-ами нет кроме того, что это именно float-ы - то есть, плохо подходят для денег и в тех местах, где нужно хранить десятичные дроби без потери точности. А если нужно обрабатывать данные мониторинга, физические рассчёты, то float-ы будут в самый раз.

теперь понятно. спасибо за ответ

ну и atod/dtoa - это боль

У столбцов (IColumn) есть метод getDataAt, который позволяет получить ссылку на кусок памяти, где расположено значение. Это работает только для простых типов. Например, для массивов уже нет. Также есть метод operator[], который позволяет получить значение в виде Field.

Спасибо. Мне, в принципе, все равно данные форматировать надо, по этому я пытаюсь Воспользоваться WriteBuffer. Постгрес воспринимает данные через их текстовое представление.

Добрый день. Обнаружил интересную особенность поведения внешних словарей CH 1.1.54245 Во всех конфигурационных файлах словарей прописаны значение параметра "Периодичность обновления для полностью загружаемых словарей": <lifetime> <min>3000</min> <max>4200</max> </lifetime> <layout> <hashed/> </layout> В основном конфиг файле config.xml СН параметр dictionaries_lazy_load не указан. Не могли бы подсказать почему внешние словари не обновляются в период, который указан в lifetime? А обновление всех словарей происходит только тогда, когда производится запрос к одному из словарей. Ошибок в логах нет. Словари висят в памяти определенное время, а потом удаляются. Заранее спасибо

dictionaries_lazy_load по-умолчанию true. В этом случае, первая загрузка словарей происходит при первом обращении к ним. После этого словари обновляются согласно указанному времени (в вашем случае примерно каждый час с разбросом в +- 10 минут). Вы говорите, что словари исчезают? Такого поведения конечно быть не должно. Как это видно? Также отмечу, что словари не перезагружаются, если можно определить, что источник не изменился (не увеличилось время модификации файла, время модификации MyISAM таблицы).

Здравствуйте. Никто не сталкивался с проблемой на очень маленьких данных (10 мб) — очень большое число parts в partition и следовательно размер partition в несколько раз больше (60 мб) чем данных в ней. Используем granularity 512, но когда закачивали основной сет размером в 6 гб таких проблем не получали.

Когда данные часто мержатся, то остаётся много старых part-ов. Они удаляются через 8 минут после мержа. Посмотреть на старые part-ы можно по значению поля active в таблице system.parts.

добрый день, вопрос актуален Alexandr Bocharov, [11.08.17 15:37] при прочих равных - SummingMergeTree vs AggregatingMergeTree у какого движка будет выше производительность, лучше потребление памяти, другие ньюансы/недостатки использования? может есть бенчмарки?

SummingMergeTree несколько (чуть-чуть) оптимальнее - по скорости мержа, и по скорости выполнения запросов. Если вам нужны только суммы, то он проще в использовании.

спасибо.

Привет всем. Ребят а как яндекс реализует отправку батчем в метрики, там же клик это одно событие, где они хранят события перед отправкой?

Как ни странно, для основного кластера мы не используем Buffer таблицы. В движок Метрики приходят данные уже в виде пачек, а эти пачки образуются для разных потоков данных одним из двух способов: - накапливаются в файлах на неких серверах, которые принимают трафик; - кладутся и вынимаются из Кафки.

Возможно ли использование поля из словаря в выражении WHERE? SELECT * FROM ( SELECT foo1, foo2, foo3, dictGetString('my_dict', 'dict_foo', tuple(toInt32(bar1), bar2)) FROM my_table WHERE date = '2017-05-11' ) AS t1 WHERE dict_foo != 'smth' LIMIT 10

Можно. Для этого, задайте в подзапросе алиас для выражения, которое достаёт данные из словаря. И используйте это имя в условии снаружи.

SELECT [1, 2] AS x, [3, 4] AS y, arrayReduce('groupArrayArray', [x, y]) AS xy ┌─x─────┬─y─────┬─xy────────┐ │ [1,2] │ [3,4] │ [1,2,3,4] │ └───────┴───────┴───────────┘

Сейчас наконец-то запланирована задача, где конкатенация массивов делается по-нормальному.

Подскажите пожалуйста, вижок AggregatingMergeTree как-то сокращает объем таблицы и или нет? Вообще какие могут быть области его применения? Спасибо

AggregatingMergeTree агрегирует данные при мержах. То есть, если было много строк для одного ключа, то после мержа останется одна, агрегированная. Мержи производятся не для всех кусков сразу - данные постоянно держатся несколько недомерженными.

Спасибо. Мне, в принципе, все равно данные форматировать надо, по этому я пытаюсь Воспользоваться WriteBuffer. Постгрес воспринимает данные через их текстовое представление.

Тогда смотрите метод IDataType::serializeTextEscaped и похожие.

Тогда смотрите метод IDataType::serializeTextEscaped и похожие.

Да, я так и сделал. Мне по сути нужно из строки char**. Я просто \t заменил на 0 и собрал указатели (через WriteBufferFromOStream+stringstream), но что-то пошло не так, завтра буду разбираться.

Да, я так и сделал. Мне по сути нужно из строки char**. Я просто \t заменил на 0 и собрал указатели (через WriteBufferFromOStream+stringstream), но что-то пошло не так, завтра буду разбираться.

Это Ок за исключением того, что строки будут лишний раз экранированы.

Ну, я сейчас делаю PoC чтобы сравнить скорость python+http с plainC+native

ERROR: S client not available

Если от С будет выхлоп - буду делать хорошо и правильно

Когда данные часто мержатся, то остаётся много старых part-ов. Они удаляются через 8 минут после мержа. Посмотреть на старые part-ы можно по значению поля active в таблице system.parts.

Много не active партов и они не удаляются уже в течении продолжительного времени...

Много не active партов и они не удаляются уже в течении продолжительного времени...

Точнее, видимо, парты постоянно создаются. Их число скачет в районе 90 штук.

В кх вставки по 20к лучше делать? или можно больше?

В кх вставки по 20к лучше делать? или можно больше?

Можно больше

можно то можно) а оптимально как?

можно то можно) а оптимально как?

Чтоб самих инсертов было мало

А размер одного инсерта был большой

а чем буферизируют в golang ? или вручную?

а чем буферизируют в golang ? или вручную?

Я к примеру просто собираю в слайс, после чего просто проверяю длинну + тикер на каждые две секунды. Т.е. или инсерт идёт при достижении 10к, или каждые две секунды

есть еще https://github.com/nikepan/clickhouse-bulk

Из самых годных вариантов как по мне - это обойтись возможностями клик хауса https://clickhouse.yandex/docs/ru/table_engines/buffer.html

там написано что даже в буффер лучше слать пачками

/stat@combot

combot.org/chat/-1001080295593

Привет Всем. Подскажите такой вопрос как можно обрывать выполнения запроса в случае если запрос приходит через http но соединение периодически обрывается? т.е. у нас получается что запрос запустился а сооединение отвалилось а запрос остался выполнятся. фигня в том что кол. данных которые перебирается уже большое и из-за таких обрывов растет загрузка на сервере и соответственно время выполнение запросов.

Скажите, пожалуйста, а можно как-то повлиять на количество parts, при превышении которого КХ начинает кидаться ошибкой "Code: 252, e.displayText() = DB::Exception: Too much parts. Merges are processing significantly slower than inserts."?

Скажите, пожалуйста, а можно как-то повлиять на количество parts, при превышении которого КХ начинает кидаться ошибкой "Code: 252, e.displayText() = DB::Exception: Too much parts. Merges are processing significantly slower than inserts."?

медленнее лить.) Это означает что мержи неуспевают за инсертами

медленнее лить.) Это означает что мержи неуспевают за инсертами

Проблема в том, что даже если ничего не лить, это количество сейас около 300. OPTIMIZE TABLE с FINAL отрабатывает моментально и ничего не делает. Вероятно это из-за того, что выполняю ее на не ведомой реплике. Но на лидирующей количество в 4 раза меньше. Проверил все варианты о которых писали, откуда такое может идти, ни одно не потвердилось. Мне бы сейчас потушить эту проблему и нормально разбраться.

Проблема в том, что даже если ничего не лить, это количество сейас около 300. OPTIMIZE TABLE с FINAL отрабатывает моментально и ничего не делает. Вероятно это из-за того, что выполняю ее на не ведомой реплике. Но на лидирующей количество в 4 раза меньше. Проверил все варианты о которых писали, откуда такое может идти, ни одно не потвердилось. Мне бы сейчас потушить эту проблему и нормально разбраться.

Там есть ограничение по размеру кусков для мержа. Возможно из-за этого не мержит

А как этот параметр называется?

Подскажите, пожалуйста, с помощью чего просуммировать математически элементы Array(UInt64), sumArray как я поняла, предназначен ля агрегации

arrayReduce

Привет всем! Кто-нибудь делал импорт в CH из Parquet файлов?

спасибо большое

А как этот параметр называется?

Ограничение на максимальный размер куска - max_bytes_to_merge_at_max_space_in_pool. Настраивается в config.xml, в секции merge_tree. Количество кусков, после которого кидается исключение о том, что кусков слишком много - parts_to_throw_insert. Обычно увеличивать не имеет смысла, так как причина часто не в том, что куски не успевают мержатся, а в том, что они не мержатся вообще, из-за каких-либо проблем.

Спасибо!

Проблема в том, что даже если ничего не лить, это количество сейас около 300. OPTIMIZE TABLE с FINAL отрабатывает моментально и ничего не делает. Вероятно это из-за того, что выполняю ее на не ведомой реплике. Но на лидирующей количество в 4 раза меньше. Проверил все варианты о которых писали, откуда такое может идти, ни одно не потвердилось. Мне бы сейчас потушить эту проблему и нормально разбраться.

Надо смотреть более внимательно. Какой делается OPTIMIZE и какие куски в таблице для данной партиции (в system.parts). Как писал в почте, наверное проблема из-за версии 54266, но это пока гипотеза. Мы знаем, что в этой версии есть проблема.

Встроенного конвертера из Parquet нет, а очень бы хотелось сделать, только не очень понятно в какой формат делать конвертацию? В Native? это самый "родной" формат для CH и самый дешевый для импорта?

Да, Native самый оптимальный. Но его труднее сформировать вручную. Второй по простоте - RowBinary. Хотя сам Parquet больше всего похож на Native, и я думаю, что родную поддержку Parquet рано или поздно придётся сделать.

Надо смотреть более внимательно. Какой делается OPTIMIZE и какие куски в таблице для данной партиции (в system.parts). Как писал в почте, наверное проблема из-за версии 54266, но это пока гипотеза. Мы знаем, что в этой версии есть проблема.

Да, откатили, запустил еще раз OPTIMZIE, лидер нагружен, на проблемной ноде пока все по старому.