- 启动bin/historyserver.sh start
- 修改flink-conf.yaml
- # Directory to upload completed jobs to. Add this directory to the list of
- # monitored directories of the HistoryServer as well (see below).
- jobmanager.archive.fs.dir: hdfs:///flink_logs/completed_jobs
- # The address under which the web-based HistoryServer listens.
- historyserver.web.address: 0.0.0.0
- # The port under which the web-based HistoryServer listens.
- historyserver.web.port: 8082
- # Comma separated list of directories to monitor for completed jobs.
- historyserver.archive.fs.dir: hdfs:///flink_logs/completed_jobs
- # Interval in milliseconds for refreshing the monitored directories.
- historyserver.archive.fs.refresh-interval: 10000
- bin/flink run -t yarn-per-job –detached ./examples/streaming/TopSpeedWindowing.jar -qu yarn.queue -p 1
作者 admin
张宴银，大数据开发工程师