Flink實現計數器

一種錯誤的實現方式：這個下面就是一種錯誤的實現方式，首先定義數據源，其中有五個單詞，而後進行數據處理，map裏面實現了RichMapFunction接口，重寫map方法，先定義一個計數器counter爲0，每讀一個單詞，counter加一，就把這個單詞變爲counter進行輸出，這裏設置的並行度爲1，輸出結果是1,2,3,4,5java 可是當咱們將並行度設置爲2的時候，輸出變成了1,2,3,1,

>>阅读原文<<