Новый узел Cassandra (назовем его c3
) был введен в наш кластер, в центр обработки данных, в котором уже было 2 других узла (c1
и c2
).nodetool repair
было выполнено в центре данных после того, как узел присоединился к кольцу.
nodetool status
сообщает, что новый узел действительно присоединился к кластеру в том же центре данных.
Datacenter: datacenter1
=======================
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
-- Address Load Tokens Owns (effective) Host ID Rack
UN xx.xx.xx.c1 48.47 GiB 256 71.0% 5908eee6-63e9-464e-9d65-b20a5f46c86c rack1
UN xx.xx.xx.c2 58.11 GiB 256 64.0% 28691036-3e11-49e9-83d6-9bbe577f7249 rack1
UN xx.xx.xx.c3 37.7 GiB 256 65.0% c8a3e0a3-0dc9-4951-b9c5-ee32dc7a12fd rack1
Arole
под названием analytics существовал в кластере до появления нового узла.В наших заданиях Spark эта роль используется для записи данных в кластер Cassandra (через соединитель Datastax Spark-Cassandra).
После добавления нового узла в моих журналах наблюдаются следующие два исключения:
java.io.IOException: Failed to write statements to reports.ts_table. The latest exception was User analytics has no MODIFY permission on <table reports.ts_table> or any of its parents.
Please check the executor logs for more exceptions and information at com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1$$anonfun$apply$3.apply(TableWriter.scala:243) ...
Cluster: Authentication error during reconnection to /xx.xx.xx.c3:9042, scheduling retry in 16000 milliseconds.
com.datastax.driver.core.exceptions.AuthenticationException: Authentication error on host /xx.xx.xx.c3:9042: Username and/or password are incorrect
Эти исключения, по-видимому, возникают, только когда запись идет во вновь добавленный узел c3
.Множественный ремонт только по схеме system_auth
и полный ремонт центра обработки данных, похоже, не решают эту проблему.Коэффициент репликации схемы system_auth
для центра обработки данных равен 2.
Любая помощь будет принята с благодарностью.Спасибо.