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

  1. demo地址:https://github.com/pacteralhw/flink_demo.git
  2. 本地部署,启动flink
    ./bin/start-clusrer.sh
  3. flink提交任务
    方式1. 在linux服务器提交:./bin/flink run -c flinkMain --port 9000 --host localhost
    方式2. 在页面提交
    在这里插入图片描述
  4. socket输入流
    nc -lk 9000
Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐