Install

$ wget http://download.nextag.com/apache/flink/flink-1.4.0/flink-1.4.0-bin-scala_2.11.tgz
$ tar xzf flink-1.4.0-bin-scala_2.11.tgz
$ cd flink-1.4.0
$ bin/start-local.sh

upload jar

rackhd@ubuntu16ip179:~/flink-1.4.0$ ./bin/flink run -c com.emc.k4m.flink.FlinkKPIStream /home/rackhd/policy_engine/BUs/k4m/k4m-flink/build/libs/k4m-flink-all-1.0.0.jar  --kpiStreamConfig "{%22name%22:%22TestKPIStream%22,%22inputs%22:[{%22type%22:%22kafka%22,%22attributes%22:{%22group.id%22:%22ngx%22,%22bootstrap.servers%22:%2210.62.59.179:9092%22,%22topic%22:%22input%22},%22formatter%22:{%22type%22:%22simpleInput%22}}],%22outputs%22:[{%22type%22:%22kafka%22,%22attributes%22:{%22bootstrap.servers%22:%2210.62.59.179:9092%22,%22topic%22:%22output%22},%22formatter%22:{%22type%22:%22simpleOutput%22}}],%22kpis%22:[{%22name%22:%22TestKPI%22,%22namespace%22:null,%22uri%22:null,%22group%22:null}],%22parallelism%22:1,%22interval%22:0,%22recurrent%22:false}" --kpiConfigs "[{%22name%22:%22TestKPI%22,%22calculation%22:{%22type%22:%22groovy%22,%22attributes%22:{%22name%22:%22sms.2g.total%22,%22metrics%22:[%22sms.2g.fail%22,%22sms.2g.success%22],%22params%22:%22smsFail,smsSuccess%22,%22value%22:%22sum(smsFail) + sum(smsSuccess)%22}},%22window%22:{%22type%22:%22sliding%22,%22attributes%22:{%22period%22:%2210000%22,%22size%22:%22300000%22}},%22type%22:%22realtime%22}]"