Flink环境搭建

安装Flink

官方介绍地址

• 下载Flink

  下载Flink并解压，Flink 官方下载地址

  Copycopy code to clipboard
  1tar xzf flink-*.tgz

• 以本地模式启动

  • 执行以下命令启动

    Copycopy code to clipboard
    1./bin/start-cluster.sh

  • 打开网址http://localhost:8081/可以查看到flink web页面

• 使用flink官方示例

  Copycopy code to clipboard
  1nc -l 9000
  2./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000

• 关闭集群

  Copycopy code to clipboard
  1./bin/stop-cluster.sh

  Flink 命令

  bin/flink

  • run
  • list
  • stop
  • cancel
  • savepoint