本文主要介绍 Flink Runtime 的作业执行的核心机制。首先介绍 Flink Runtime 的整体架构以及 Job 的基本执行流程，然后介绍Flink 的Standalone运行架构，最后对Flink on YARN的两种模式进行了详细剖析。
分类
Flink运行架构剖析
Author: wangzhengzhen
Spring Data Redis 的 RedisTemplate 对 Redis 进行了封装。在对某值调用increment()方法时报错：
redis ERR value is not an integer or out of range
redisTemplate.opsForValue().increment(key);
大家都知道redis序列化是将key，value值先转换为流的形式，再存储到redis中。
RedisTemplate是使用的JdkSerializationRedisSerializer序列化，序列化后的值包含了对象信息，版本号，类信息等，是一串字符串，所以无法进行数值自增操作。
而StringRedisTemplate序列化策略是字符串的值直接转为字节数组，所以存储到redis中是数值，所以可以进行自增操作。
用Java把Flink结果数据下沉到Elasticsearch，执行时执出ElasticsearchSinkFunction is not serializable异常：
The implementation of the provided ElasticsearchSinkFunction is not serializable. The object probably contains or references non-serializable fields.
本站开通也有好几年了，除了更新几次主题，自定义几个样式和几处微调，没什么做大的改动。这次心血来潮把它优化一波，为后面使用打下基础。
次此优化主要是：
- 优化php配置
- 优化wordpress一些不适合国情的东西(你懂的)
- 优化链接便于搜索引擎收录
Elasticsearch默认启动监听的是本地127.0.0.1端口，现需要把服务发布出来，供其他机器访问。修改Elasticsearch配置文件(config/elasticsearch.yml)：
network.host: 0.0.0.0
discovery.seed_hosts: ["0.0.0.0"]启动后报错，如图：
ERROR: [1] bootstrap checks failed
[1]: max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144]Linux使用Samba挂载网络共享需安装cifs工具，在Ubuntu下安装：
sudo apt install cifs-utils然后可以用mount挂载：
sudo mount.cifs //ip/共享目录 挂载目录默认挂载后所有文件所属用户和组都是root，可以增加参数指定用户。
sudo mount.cifs -o rw,uid=wangzhengzhen,username=guest,password= //ip/共享目录 挂载目录Function
- Function作为一个函数式接口，主要方法apply接收一个参数，返回一个值
@FunctionalInterface
public interface Function<T, R> {
/**
* Applies this function to the given argument.
*
* @param t the function argument
* @return the function result
*/
R apply(T t);
}在函数式语言中，函数作为一等公民，可以在任何地方定义，在函数内或函数外，可以作为函数的参数和返回值，可以对函数进行组合。由于命令式编程语言也可以通过类似函数指针的方式来实现高阶函数，函数式的最主要的好处主要是不可变性带来的。没有可变的状态，函数就是引用透明（Referential transparency）的和没有副作用（No Side Effect）。
任何一种函数式语言中，都有map函数与faltMap这两个函数，比如python虽然不是纯函数式语言，也有这两个函数。再比如在jdk1.8之后，也加入了Lambda表达式，自然也支持map函数。
DateTimeFormatter 和 SimpleDateFormat
- DateTimeFormatter 线程安全 ，SimpleDateFormat 非线程安全
- DateTimeFormatter是Java8提供的新方式
- 单线程环境下DateTimeFormatter和LocalDateTime的parse性能比SimpleDateFormat的parse性能高
- 多线程环境下DateTimeFormatter作为共享变量时，大部分情况下性能比SimpleDateFormat高(因为多线程环境的复杂性，此结论不一定准确)
在虚拟机启动Linux系统做共享，使用Samba协议，速度最多30M上下，而且不太稳定。因为系统是安装在物理硬盘的，如果不通过虚拟机启动，速度可以到100M以上。估计是网卡问题。
原来默认的VMware安装的硬件网卡是AMD PCnet32，这两个都是10M网卡。所以需要对配置进行修改。