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}