1. 程式人生 > >Flink的standalone 模式簡單部署

Flink的standalone 模式簡單部署

flink-conf.yaml 檔案中進行一下配置:

jobmanager.rpc.address: 10.8.45.10


# The RPC port where the JobManager is reachable.


jobmanager.rpc.port: 6123




# The heap size for the JobManager JVM


jobmanager.heap.mb: 4096




# The heap size for the TaskManager JVM


taskmanager.heap.mb: 4096




# The number of task slots that each TaskManager offers. Each slot runs one parallel pipeline.


taskmanager.numberOfTaskSlots: 4


# Specify whether TaskManager memory should be allocated when starting up (true) or when
# memory is required in the memory manager (false)


taskmanager.memory.preallocate: false


# The parallelism used for programs that did not specify and other parallelism.


parallelism.default: 4




#==============================================================================
# Web Frontend
#==============================================================================


# The address under which the web-based runtime monitor listens.
#
#jobmanager.web.address: 0.0.0.0


# The port under which the web-based runtime monitor listens.
# A value of -1 deactivates the web server.


jobmanager.web.port: 8081


啟動:

在bin目錄下執行 : ./start-cluster.sh  即可

總體來看,基本的叢集操作配置與 hadoop spark 等分散式平臺部署沒啥區別