flink运行一段时间,报内存溢出,下面是运行参数,和报错,设置了很大的taskmanager内存,还是不行,有没有人懂🙏🏻
flink run \
-t yarn-per-job \
-d \
-p 10 \
-Drest.flamegraph.enabled=true \
-Dyarn.application.queue=default \
-Drest.flamegraph.enabled=true \
-Djobmanager.memory.process.size=2048mb \
-Dtaskmanager.memory.process.size=49152mb \
-Dtaskmanager.numberOfTaskSlots=2 \
-Dtaskmanager.memory.jvm-metaspace.size=512mb \
-Dtaskmanager.memory.jvm-overhead.max=2048mb \
-Dstate.backend.rocksdb.block.blocksize=64kb \
-Dstate.backend.rocksdb.block.cache-size=128mb \
-Dstate.backend.rocksdb.writebuffer.size=128mb \
-Dstate.backend.rocksdb.compaction.style=level \
-Dstate.backend.rocksdb.compaction.level.max-size-level-base=320m \
-Dstate.backend.rocksdb.writebuffer.count=5 \
-Dstate.backend.rocksdb.thread.num=8 \
-Dtaskmanager.memory.jvm-overhead.fraction=0.3 \
-Dstate.backend.rocksdb.checkpoint.transfer.thread.num=8 \
-Dstate.backend.rocksdb.writebuffer.number-to-merge=3 \
-Dstate.backend.rocksdb.metrics.block-cache-usage=true \
-Dstate.backend.rocksdb.memory.partitioned-index-filters=true \
-Dtaskmanager.memory.network.max=2048mb \
-Denv.java.opts="-Dfile.encoding=UTF-8" \
-Dyarn.application.name=beta_hunter_fault_matching \
-c cn.seres.beta.realtime.app.BetaHunterVehicleFaultMatchApp \
/root/beta_flink_lib/beta_hunter_fault_match-1.2-SNAPSHOT.jar