http://vinoyang.com/2016/05/05/flink-stream-source/
http://vinoyang.com/2017/01/26/flink-runtime-specific-task/