备注:本地demo仅用作记录,对于其他类似demo类似,并无特别之处。
- demo地址:https://github.com/pacteralhw/flink_demo.git本地部署,启动flink
./bin/start-clusrer.shflink提交任务
方式1. 在linux服务器提交:./bin/flink run -c flinkMain --port 9000 --host localhost
方式2. 在页面提交
socket输入流
nc -lk 9000

备注:本地demo仅用作记录,对于其他类似demo类似,并无特别之处。