Flink+kafka+redisリアルタイム計算wordcount

前回はローカルでwordcountを走りましたが、今日はフロー式の計算wordcountを書き、kafkaのデータを読み出してリアルタイムの計算を行い、結果をredisに書きました.
pomファイルは次のとおりです.

            org.apache.flink
            flink-scala_2.11
            1.6.0
        
        
            org.apache.flink
            flink-clients_2.11
            1.6.0
        
        
            org.apache.flink
            flink-streaming-scala_2.11
            1.6.0
        
        
            org.apache.flink