включить debug на kafka , скорее всего не может распарсить сообщение

Имеется таблица с buffer, которая будет сбрасывать в таблицу engine=null, на которую настроены mv для последующего распределения данных. Если при вставке в каком-то mv выдаст ошибку, буферизированный кусок данных потеряется ?

это в кликхаусе или в самой кафке?

в этом чате точно ответа нет. И это очень очень минорная проблема, и очень нетрадиционное использование КХ

да

в кх

Благодарю.

ну  баг где-то в описании кластера, если добавить в запрос к distributed select hostName() - думаю станет понятнее

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

что тут может быть не так?
<yandex>
 <remote_servers>
   <cluser>
     <shard>
         <internal_replication>true</internal_replication>
         <replica>
             <default_database>shard_1</default_database>
             <host>192.168.56.1</host>
             <port>9000</port>
         </replica>
         <replica>
             <default_database>shard_1</default_database>
             <host>192.168.56.2</host>
             <port>9000</port>
         </replica>
     </shard>
     <shard>
         <internal_replication>true</internal_replication>
         <replica>
             <default_database>shard_2</default_database>
             <host>192.168.56.2</host>
             <port>9000</port>
         </replica>
         <replica>
             <default_database>shard_2</default_database>
             <host>192.168.56.3</host>
             <port>9000</port>
         </replica>
     </shard>
     <shard>
         <internal_replication>true</internal_replication>
         <replica>
              <default_database>shard_3</default_database>
             <host>192.168.56.3</host>
             <port>9000</port>
         </replica>
         <replica>
             <default_database>shard_3</default_database>
             <host>192.168.56.1</host>
             <port>9000</port>
         </replica>
     </shard>
   </cluser>
 </remote_servers>
</yandex>

типа ранк сквозь все департаменты и плюс минимальную зарплату в каждом?

salaries[rank] ?

а нет, все равно будет не тот

в итоге ожидаю такую картину)

runningAccumulate мб?

а ну если у вас через массивы, то лучше тогда

arrayFill((x,y,z)-> (y!=deptids[y]),salaries,deptids,range(length(salaries)))

и этот конфиг одинаковый на всех серверах?
а таблицы replicated ?
а select count() from shard_1. совпадают на репликах?

конфиг на всех серверах одинаковый. select count() from shard_1 на репликах не совподат
таблицы ReplicatedMergeTree создаю
server-1:
CREATE TABLE shard_1.tc_shard ... ENGINE = ReplicatedMergeTree( '/clickhouse/tables/shard_1/events', '{replica00}', date, (intHash32(user_id), intHash32(login), date), 8192);
CREATE TABLE shard_3.tc_shard ... ENGINE = ReplicatedMergeTree( '/clickhouse/tables/shard_3/events', '{replica01}', date, (intHash32(user_id), intHash32(login), date), 8192);

server-2:

CREATE TABLE shard_3.tc_shard ... ENGINE = ReplicatedMergeTree( '/clickhouse/tables/shard_3/events', '{replica00}', date, (intHash32(user_id), intHash32(login), date), 8192);
CREATE TABLE shard_2.tc_shard ... ENGINE = ReplicatedMergeTree( '/clickhouse/tables/shard_2/events', '{replica01}', date, (intHash32(user_id), intHash32(login), date), 8192);

server-3:
CREATE TABLE shard_2.tc_shard ... ENGINE = ReplicatedMergeTree( '/clickhouse/tables/shard_2/events', '{replica00}', date, (intHash32(user_id), intHash32(login), date), 8192);
CREATE TABLE shard_1.tc_shard ... ENGINE = ReplicatedMergeTree( '/clickhouse/tables/shard_1/events', '{replica01}', date, (intHash32(user_id), intHash32(login), date), 8192);

server-1 - 192.168.56.1
server-2 - 192.168.56.2
server-3  - 192.168.56.3
?
не совпадает тогда

/stat@combot