apache-flink - flink集群启动错误[ERROR]无法正确获取JVM参数

标签 apache-flink flink-streaming

$ 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.

我在所有master和slave中都有$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/#/task-manager

最佳答案

您配置了conf/slaves 文件吗?请参阅https://ci.apache.org/projects/flink/flink-docs-stable/ops/deployment/cluster_setup.html#configuring-flink .

jps 的问题看起来不像 Flink 的问题。从机上真的有JDK吗?

关于apache-flink - flink集群启动错误[ERROR]无法正确获取JVM参数,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60615984/

相关文章:

scala - 如何使用 Apache flink 处理乱序事件?

apache-flink - 如何通过 Flink Table API/SQL 中的数据流 API 在给定键和公共(public)窗口上连接三个或更多数据流/表?

java - 无法使用Flink-nifi连接器从Nifi输出端口读取数据

apache-flink - 根据 Flink 的模式使用 GCS 文件

java - Flink webUI 中的 "No Metrics "

apache-flink - 在 Flink 中检查点时,计时器过多会花费太多时间

java - 为什么 Apache Flink 从数据流中删除事件?

google-cloud-storage - Flink 检查点到 Google Cloud Storage

apache-flink - Flink 一个作业中的多个作业或多个管道

hadoop - 为什么Flink 1.4中的每个处理插槽都使用单独的内核?