Environment
2 machines, 203204
plans to run jobmanager
and taskmanager
master
hz203:9081
hz204:9081
slaves
hz203
hz204
flink-conf.yaml
jobmanager.rpc.port: 6123
rest.port: 9081
blob.server.port: 6124
query.server.port: 6125
web.tmpdir: /home/ctu/flink/deploy/webTmp
web.log.path: /home/ctu/flink/deploy/log
taskmanager.tmp.dirs: /home/ctu/flink/deploy/taskManagerTmp
high-availability: zookeeper
high-availability.storageDir: file:///home/ctu/flink/deploy/HA
high-availability.zookeeper.quorum: 10.0.1.79:2181
high-availability.zookeeper.path.root: /flink
high-availability.cluster-id: /flink
run . / start-cluster.sh
question
-
akka.tcp://flink@127.0.0.1:33567/user/resourcemanager
ip has always been 127.0.0.1, not the ip of -
high-availability.storageDir
if it ishdfs://
, do you have to installhadoop
to runjobmanager
andtaskmanager
(there arehdfs://
on other machines), usehdfs://xxxx
to promptCLASSPATH
thathadoop
cannot be found.
jobmanager
in the masters
file.
@ codecraft @ Fan Lei Thank you