Apache Flink是一个开源的流处理框架，提供了分布式的、高性能的、高可用的特性，同时能够为流式应用程序提供多种编程语言的API，更多有关Flink的内容，不再累述，请参考官方文档，本文主要以Flink Standalone集群安装配置、编程实践为主。 Flink集群安装配置 首先，选择一主二从共3个节点来安装配置Flink Standalone集群： Master：ali-bj01-tst-cluster-001.xiweiai.cn Worker：ali-bj01-tst-cluster-002.xiweiai.cn Worker：ali-bj01-tst-cluster-003.xiweiai.cn 为了方便安装文件远程拷贝，单独创建一个hadoop用户，并打通从Master节点使用ssh到Worker节点之间的免密码登录。 在Master节点上下载、准备Flink 1.4.0安装文件，执行如下命令： wget http://mirror.bit.edu.cn/apache/flink/flink-1.4.0/flink-1.4.0-bin-hadoop26-scala_2.11.tgz tar xvzf flink-1.4.0-bin-hadoop26-scala_2.11.tgz 接着，修改Flink配置文件flink-1.4.0/conf/flink-conf.yaml，修改后的内容如下所示： env.java.home: /usr/local/java/jdk1.8.0_131/ jobmanager.rpc.