qingbo
08/14/2023, 10:16 AMspec:
flinkConfiguration:
blob.server.port: β6124β
fs.local.impl: org.apache.flink.core.fs.local.LocalFileSystem
high-availability.jobmanager.port: β50010"
high-availability.storageDir: s3://XXX
high-availability.zookeeper.client.connection-timeout: β30000β
high-availability.zookeeper.client.maxSessionTimeout: β30000"
high-availability.zookeeper.client.session-timeout: β30000β
jobmanager.archive.fs.dir: s3://XXX
jobmanager.memory.heap.size: 512mb
jobmanager.memory.jvm-metaspace.size: 256mb
jobmanager.memory.jvm-overhead.max: 2000mb
jobmanager.memory.jvm-overhead.min: 100mb
jobmanager.memory.process.size: 1024mb
jobmanager.rpc.port: β6123"
kubernetes.operator.jm-deployment-recovery.enabled: βfalseβ
parallelism.default: β1"
queryable-state.proxy.ports: β6125β
recovery.mode: zookeeper
recovery.zookeeper.path.namespace: /flink_operator
recovery.zookeeper.path.root: /flink_iot_operator
recovery.zookeeper.quorum: zookeeper-ingest-headless:2181
s3.access-key: XXX
s3.secret-key: XXX
state.backend: rocksdb
state.backend.async: βtrueβ
state.backend.fs.memory-threshold: β1024β
state.backend.fs.write-buffer-size: β4096"
state.backend.incremental: βtrueβ
state.backend.local-recovery: βfalseβ
state.backend.rocksdb.checkpoint.transfer.thread.num: β1β
state.backend.rocksdb.localdir: /opt/flink/data/rocksdb
state.backend.rocksdb.metrics.actual-delayed-write-rate: βtrueβ
state.backend.rocksdb.metrics.background-errors: βtrueβ
state.backend.rocksdb.options-factory: org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory
state.backend.rocksdb.predefined-options: DEFAULT
state.backend.rocksdb.timer-service.factory: HEAP
state.backend.rocksdb.ttl.compaction.filter.enabled: βfalseβ
state.checkpoints.dir: s3://XXX
state.checkpoints.num-retained: β100β
state.savepoints.dir: s3://XXX
taskmanager.memory.jvm-metaspace.size: 256mb
taskmanager.memory.jvm-overhead.min: 64mb
taskmanager.memory.managed.size: 512mb
taskmanager.memory.process.size: 3328mb
taskmanager.memory.task.heap.size: 2048mb
taskmanager.memory.task.off-heap.size: 256mb
taskmanager.numberOfTaskSlots: β4"
taskmanager.rpc.port: β6122β
taskmanager.state.local.root-dirs: /opt/flink/data/local-recovery
flinkVersion: v1_14