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 等分布式平台部署没啥区别