Всем привет. Нужна помощь. Запускаю spark-submit локально на мастер ноде aws emr. Все валится. В логах пишет все время:org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /hbase/hbaseid
Джоб должен подключаться к hbase. Судя по логам пытается локально на экзекьбторе найти зукипер :20/01/30 16:18:55 WARN ReadOnlyZKClient: 0x334f9b75 to localhost:2181 failed for get of /hbase/hbaseid, code = CONNECTIONLOSS, retries = 30, give up
Джоб должен подключаться к hbase. Судя по логам пытается локально на экзекьбторе найти зукипер :20/01/30 16:18:55 WARN ReadOnlyZKClient: 0x334f9b75 to localhost:2181 failed for get of /hbase/hbaseid, code = CONNECTIONLOSS, retries = 30, give up
Там вроде какой то параметр был, чтобы указать zk quorum, если он указан, значит где-то теряется. Могу предположить, что в executor при старте надо добавить конфиг в cp.
А как в Flink подсунуть джобе значение hbase.zookeeper.qourum? Пока только в ресурсах джобы получается xml файл держать..получается что адрес захардкожен в jar-нике