IP-адрес активного мастера и mtime не обновляются в master_status znode, созданном с помощью spark

Я настроил Spark для HA, используя

SPARK_DAEMON_JAVA_OPTS="-Dspark.deploy.recoveryMode=ZOOKEEPER -Dspark.deploy.zookeeper.url=zkServer1:2181,zkServer2:2181,zkServer3:2181"

Таким образом, он создает два znodes master_status и leader_election в зоопарке. master_status хранит информацию об активном мастере, а его дочерние элементы содержат информацию о работающих работниках и приложениях.

Теперь проблема, которую я имею, это IP 10.10.3.72 который вы видите, не является IP-адресом текущего активного мастера. Хотя дочерние узлы содержат правильную информацию о работающих работниках и искровых приложениях. Более того, как вы можете видеть mtime не обновлялся после 4 апреля 2018 года, хотя активный мастер был смещен после 4 апреля 2018 года. Это ошибка в Spark?

я использую spark-2.2.1 а также zookeeer-3.3.6

0 ответов

Другие вопросы по тегам