соединитель искры-кассандры, ограничение попыток повторных попыток для мертвого узла кассандры - PullRequest
1 голос
/ 17 марта 2020

@ здесь: мы запускаем cassandra в kuberenetes и используем коннектор spark-cassandra, проблема, с которой мы сталкиваемся, заключается в перезапусках POD для kubernetes, изменения IP-адреса cassandra

при каждом изменении ip-адреса cassandra (перезапуск cassandra) рабочие журналы, мы видим старый ip как DOWN, и мы можем видеть новый замененный IP как недавно добавленный узел, и устанавливаются соединения с новым модулем с правильным POD_IP, который является правильным, но проблема в том, что мы также видим, что соединения все еще идут к старому pod_ip и попытка все еще происходит со старым мертвым pod_ip

com.datastax.driver.core.Host.STATES: Defuncting Connection[/100.96.1.4:9042-1, inFlight=0, closed=false] because: [/100.96.1.4:9042] Cannot connect
com.datastax.driver.core.exceptions.TransportException: [/100.96.1.4:9042] Cannot connect

любая попытка повторного подключения коннектора искровой кассандры, которую я могу установить, чтобы ограничить число попыток повторных попыток для мертвого узла это предупреждение, которое я вижу только в журнале искателя-работника любую политику переподключения похож на тот, что в java драйвере, который мы можем настроить в spark-cassandra-разъем?

...