Flink是新的stream计算引擎,用java实现。既可以处理streamdata也可以处理batchdata,可以同时兼顾Spark以及Sparkstreaming的功能,与Spark不同的是,Flink本质上只有stream的概念,batch被认为是specialstream。Flink在运行中主要有三个组件组成,JobClient,JobManager和TaskManager。主要工作原理如下图用户首先提交Flink程序到JobClient,经过JobClient的处理、解析、优化提交到