首页 笔记 图片 查字 
所属分类:Flink
浏览:156
内容:


read=2
write=2
jm=1024
tm=2048
appname=test_flink_per_job_mode

flink run -t yarn-per-job
    -Dyarn.application.name=${appname}
    -Djobmanager.memory.process.size=${jm}mb
    -Dtaskmanager.memory.process.size=${tm}mb
    -Dtaskmanager.memory.managed.fraction=0.5
    --class org.test.TestAPP
    /root/test/testapp.jar -input hdfs://master:9000/test/data/input.log -output hdfs://master:9000/test/output/output.log  -read ${read} -write ${write}