6.利用flink-jdbc将数据保存到数据库。3.datav连接阿里云mysql数据库。2.搭建阿里云rds云数据库。4.编写kafka生产者代码。5.编写flink消费者代码。1.首先搭建kafka集群。

在分布式文件系统启动的时候，开始的时候会有安全模式，当分布式文件系统处于安全模式的情况下，文件系统中的内容不允许修改也不允许删除，直到安全模式结束。运行期通过命令也可以进入安全模式。执行hadoop jar命令，在hadoop的/apps/hadoop/share/hadoop/mapreduce路径下存在hadoop-mapreduce-examples-2.6.0-cdh5.4.5.jar包，