study and program test on Apache Flink