[email protected] software $ tar zxvf flink ...">

当前位置：网站首页>Flink deploys and submits jobs

Flink deploys and submits jobs

2022-08-01 01:19:00 【Craftsman Sanshi brother】

1. Flink deployment and page submission

  1. Install
#Unzip the flink installation package to /opt/module/[[email protected] software]$ tar -zxvf flink-1.10.1-bin-scala_2.12.span>tgz -C /opt/module/
  1. Start
[[email protected] bin]$ ./start-cluster.sh
  1. View page
    insert image description here
  2. Local packaging
    insert image description here
    [Note] install herewhen an error occurs.The problem in the final verification is that the directory to which my project belongs and the maven directory are all in the Chinese path.Therefore, it is necessary to change the Chinese directory to English, otherwise an error will be reported when compiling.
  3. Upload the jar package to the system
    insert image description here
  4. Writing parameters
    insert image description here
  5. Submit task
    insert image description here
  6. The server opens the port and transmits data
    insert image description here
  7. View result output
    insert image description here
    Second,Server Submission
  8. Command Line Launcher
[[email protected] bin]$ ./flink run -c com.yili.StreamWordCount -p 2 /opt/module/flink-1.10.1/project/FlinkTutorial-1.0-SNAPSHOT-jar-with-dependencies.jar --host localhost --port 7777

insert image description here
insert image description here

  1. Command line view task list
[[email protected] bin]$ ./flink list

insert image description here

  1. Command line stop task
[[email protected] bin]$ ./flink cancel d4c209b30c2ff36850d8c24c0b305eca

insert image description here

  1. Command line to view all tasks including running and stopped
[[email protected] bin]$ ./flink list -a

insert image description here
insert image description here

原网站

版权声明
本文为[Craftsman Sanshi brother]所创，转载请带上原文链接，感谢
https://yzsam.com/2022/213/202208010108465397.html

边栏推荐

猜你喜欢

随机推荐