Flink实现计数器

一种错误的实现方式：这个下面就是一种错误的实现方式，首先定义数据源，其中有五个单词，而后进行数据处理，map里面实现了RichMapFunction接口，重写map方法，先定义一个计数器counter为0，每读一个单词，counter加一，就把这个单词变为counter进行输出，这里设置的并行度为1，输出结果是1,2,3,4,5java 可是当咱们将并行度设置为2的时候，输出变成了1,2,3,1,

>>阅读原文<<