Ошибка запуска кластера flink [ОШИБКА] Не удалось правильно получить параметры JVM - PullRequest
Новая
       5

Ошибка запуска кластера flink [ОШИБКА] Не удалось правильно получить параметры JVM

1 голос
/ 10 марта 2020 
$ bin/start-cluster.sh
Starting cluster.
[INFO] 1 instance(s) of standalonesession are already running on centos1.
Starting standalonesession daemon on host centos1.
[ERROR] Could not get JVM parameters properly.
[ERROR] Could not get JVM parameters properly.

У меня есть $ JAVA_HOME во всех ведущем и подчиненных 

]$ echo $JAVA_HOME
/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.242.b08-0.el7_7.x86_64/

Ниже приведены настройки файла конфигурации. 

jobmanager.rpc.address: 10.0.2.4
# The RPC port where the JobManager is reachable.
jobmanager.rpc.port: 6123
taskmanager.numberOfTaskSlots: 5
parallelism.default: 2

JPS в главном: 

]# jps
30944 QuorumPeerMain
9600 StandaloneSessionClusterEntrypoint
31640 ConsoleProducer
32889 Jps
31278 Kafka

в ведомом устройстве Я не могу увидеть вывод команды jps: 

# jps
-bash: jps: command not found

Также в диспетчере задач я не вижу записей. http://10.x.x.x: 8081 / # / проблемно-менеджер

1 Ответ

2 голосов
/ 10 марта 2020

Вы настраивали файл conf / slaves? См. https://ci.apache.org/projects/flink/flink-docs-stable/ops/deployment/cluster_setup.html#configuring -flink .

Проблема с jps не похожа на проблему с Flink. Действительно ли JDK на рабе?

...