四、使用flink-job创建flink集群1.说明1.首先flink-client将一个job提交到yarn。2.yarn为这个application启动一个临时flink集群3.application运行结束后后,yarn关闭临时flink集群2. 运行程序2.1 启动命令$FLINK_HOME/bin/flink run -m yarn-cluster -yn 3/bigdata/sof

五、flink-on-yarn实现原理1.通过配置信息找到yarna.Flink-Yarn-Client(FRC)读取YARN_CONF_DIR,HADOOP_CONF_DIR或HADOOP_CONF_PATH环境变量。b.如果a读取不到，则flink-yarn-client读取HADOOP_HOME环境变量，如果读到HADOOP_HOME若安装的是Hadoop2,

二、开发并运行flink程序1. 创建package和object（略）2. 编写程序package code.book.idetesimport org.apache.flink.api.scala._object WordCountJob {def main(args: Array[String]) {// 1.设置运行环境val env = ExecutionEn

第一部分：flink概况一、flink简介 1.flink和spark类似，是一个通用的，基于内存计算的，大数据处理引擎。2.2009年是德国柏林理工大学一个研究性项目，用Java和Scala混合编写而成的。原项目名称为stratosphere项目地址为http://stratosphere.eu3.2014年被Apache孵化器所接受，迅速地成为了阿帕奇顶级项目ASF(Apache So

第一部分：flink概况一、flink简介1.flink和spark类似，是一个通用的，基于内存计算的，大数据处理引擎。2.2009年是德国柏林理工大学一个研究性项目，用Java和Scala混合编写而成的。原项目名称为stratosphere项目地址为http://stratosphere.eu3.2014年被Apache孵化器所接受，迅速地成为了阿帕奇顶级项目ASF(Apache Sof

参考《和我一步步部署 KUBERNETES 集群》，将其部署步骤通过ansible playbook实现自动化部署。https://www.gitbook.com/book/opsnull/follow-me-install-kubernetes-cluster/details环境要求实验环境通过MBP下的virtualbox和vagrant来提供3台虚拟机(centos 7)进行部署，其