??????????????????????????????????????????????
????????flink????????????????1.7.2??hadoop??????2.8.5,????flink on yarn ha?????????????????? run a job on yarn 1.????????????env.enableCheckpointing(5000);???????????????? 2019-04-04 13:23:50,176 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 2707 @ 1554355430174 for job c6028596fef272ae93bf4cfb625a48c9. 2019-04-04 13:23:50,218 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 2707 for job c6028596fef272ae93bf4cfb625a48c9 (13472 bytes in 33 ms). ??????????checkpoint??????5????????????????????????????yarn ??????????jobmanager.log?????????????????????????????? ?? ?????????????????????? jobmanager.err : Total file length is 573 bytes. jobmanager.log : Total file length is 363370 bytes. jobmanager.out : Total file length is 0 bytes. 3.??????????????????????????????????????????????????????????????????es??????????????????????????????????????????????????????????????????????container_id,?????????????????? ?????????????????????????????????????????????? 4.??????????????????????????????????????flink??????????????????????????yarn??????????????(????????????????????????????????)??????????????????????????????????????????????3?????????????????????????????? ------------------ ???????? ------------------ ??????: "Biao Liu"<[email protected]>; ????????: 2019??4??4??(??????) ????11:14 ??????: "user-zh"<[email protected]>; ????: Re: flink on yarn ???? ???????? Hi, ??????Flink ???????????????????????????????????? checkpoint ???????? log ????(???????????????????????????????????????????????? log ????) 1. log ?????? log4j/logback ??????????????????conf ?????????????????????????????????????????? logger ?? level?????????????????????? 2. Flink on YARN ???????????????? log ?????? Flink web UI ???????????????????????????? log ??????Application ???????????????????????? container ???????????????????? log ?????????????????????? HDFS ?????????? YARN ???????? 3. log ???????????????????????????????? https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/logging.html??????Flink ???????????????????????????????????????????????????? 1900 <[email protected]> ??2019??4??4?????? ????10:45?????? > ????????????????????env.enableCheckpointing(5000); > ??????????????????????????????????????????????????yarn???? > ??job???????????????????????????????? > 1.?????????????????????????????????????????????????? > 2.????????????????????????????????????????????????????????????????????hdfs?? > 3.????flink????????????????????????????????slf4j+logback????on yarn > ????????????????????????????????????????????????????????????????????????????????????????????????????hdfs????
