直接下载 解压,
运行 ./bin/start-cluster.sh
几个概念:
批处理: 大数据量,不要求实时。 输入源是有界的
流处理:实时要求高,通常在毫秒级, 数据量比较小,但是输入源是无界的
采集 (来源MQ, stream...)--> translate(实时计算,批计算) --> sink (保存到数据库或者mq)
idea中调试flink程序
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
可以自动查找到当前flink环境