1. Flink部署下载安装文件 https://flink.apache.org/downloads.html#apache-flink-1100 这里部署standalone模式，只需要进入bin目录执行 start-cluster.s

在上一篇中已经介绍了 YARN 的整体架构：ResourceManager（RM）负责集群资源调度，NodeManager（NM）负责单机资源管理，ApplicationMaster（AM）负责单个应用的生命周期管理，Container 则

由于第二章为 Hadoop 环境安装内容，此处略过。环境安装可以参考：Ambari 的安装文档 1. Hadoop 架构的变迁 YARN 提供了运行非 MapReduce 应用的新能力，为 Hadoop 生态增加了很多新特性。 2. YAR

前段时间在虚拟机安装ambari之后一直也没有做测试，今天起来将集群启动发现有些组件启动时遇见一些问题，在这里记录一下。 1. DataNode 无法启动DataNode启动成功后就死掉了。 1.1 查看DataNode日志寻找原因首先在D

1. 插件的使用首先进入到 Hexo 博客的根目录，执行 npm install hexo-simple-mindmap 安装插件。 写新文章时，在需要脑图的地方，按以下格式添加内容。插件会自动将 pullquote 中包裹的内容按照层级顺

Apache Hadoop YARN （Yet Another Resource Negotiator，另一种资源协调者）是一种新的 Hadoop 资源管理器。它是一个通用资源管理系统，可为上层应用提供统一的资源管理和调度。它的引入为集群

1. Flink 是什么？Apache Flink 是一个分布式大数据处理引擎，可对有界数据流和无界数据流进行有状态或无状态的计算，能够部署在各种集群环境，对各种规模大小的数据进行快速计算。 Apache Flink 功能强大，支持开发和运

1.介绍AKKA是java虚拟机jvm平台上构建高并发、分布式和容错应用的工具包和运行时. akka用scala语言编写，同时提供了scala和java接口 官网：https://akka.io/ ActorSystem：创建并监听act

1. IOimport java.io._, java.nio._ object IODemo{ def main(args: Array[String]): Unit = { val path = "D:

1. 隐式转换 隐式转换是scala中一种特殊的功能，能在不改动已有class设计的情况下为class添加新的方法 隐式转换是把一种类型安全地转成另一种类型，原数据类型将拥有新的数据类型的所有方法，也可以看成是对类的一种增强 定义隐式转换的

1. 泛型类 泛型类就是在类的声明中，定义一些泛型类型。然后类内部的字段或者方法就可以使用这些泛型类型 使用泛型类通常是需要对类中的某些成员(字段、方法中的参数或变量)进行统一的类型限制，这样可以保证程序更好的健壮性和稳定性 如果不使用泛型

1. 对象（object）在scala 中被object 关键字修饰的类有一下特征 没有 有参数的主构造器， 但是有主构造器代码块(不包含在任何方法中的代码，就是主构造器代码) 它是单例的所以主构造器代码块只会执行一次 不需要通过关键字