1、ssh端口号
修改默认ssh端口号：export FLINK_SSH_OPTS="-p 53742"

2、flink-conf.yaml

#---------------->memory begin<--------------
#flink 1.10 config start .............
taskmanager.memory.managed.fraction:  0.5
taskmanager.memory.jvm-metaspace.size: 256m
#flink 1.10 config stop ..............

#--------------->Failure Rate Restart Strategy<----------------
restart-strategy: failure-rate
restart-strategy.failure-rate.max-failures-per-interval: 5000
restart-strategy.failure-rate.failure-rate-interval: 6 min
restart-strategy.failure-rate.delay: 1 s

#---------------->checkpoint begin<--------------
#enable rocksdb to be the backend
state.backend: rocksdb

#filesystem to store checkpoint meta data (when external checkpoint enabled.)
state.checkpoints.dir: hdfs://{{cluster_name}}/user/flink_bu/xxx-fs-checkpoints/cpk/1_3

#filesystem to store checkpoint data
state.backend.fs.checkpointdir: hdfs://{{cluster_name}}/user/flink_bu/xxx-fs-checkpoints/cpk/1_3

#---------------->HA begin<--------------
#enable HA with zk
high-availability: zookeeper

#zk quorm
high-availability.zookeeper.quorum: {{zk_link}}

#only the directory point will stored in zk, data will be stored in the pointed file system
high-availability.zookeeper.storageDir: hdfs://{{cluster_name}}/user/flink_bu/HA/

#!!!important, this needed be unique per cluster.
high-availability.zookeeper.path.root: /flink_bu

#times container failed can be accepted.
yarn.maximum-failed-containers: 10

#times application failed can be accepted.
yarn.application-attempts: 10

# akka config
heartbeat.timeout: 180000

blob.service.cleanup.interval: 1800

akka.tcp.timeout: 60 s

akka.lookup.timeout: 60 s

akka.ask.timeout: 100 s

akka.client.timeout: 600 s

akka.framesize: 1048576000b
#--------------->blobStore begin<---------------
#
#only useful for non HA model
blob.storage.directory: /tmp

#--------------->Defines whether user-jars are included in the system class path for per-job-clusters as well as their positioning in the path<---------------------
yarn.per-job-cluster.include-user-jar: FIRST




state.backend.rocksdb.metrics.column-family-as-variable: true

state.backend.rocksdb.compaction.level.max-size-level-base: 512M
state.backend.rocksdb.block.cache-size: 512M
state.backend.rocksdb.compaction.level.target-file-size-base: 32M
state.backend.rocksdb.compaction.level.use-dynamic-size: true
state.backend.rocksdb.thread.num: 2
state.backend.rocksdb.writebuffer.size: 128M

security.kerberos.login.use-ticket-cache: true
security.kerberos.login.keytab: {{flink_bu_keytab_file}}
security.kerberos.login.principal: {{flink_bu_principal}}