解决Flink Checkpoint snapshotState方法无法回调的问题

参考：https://stackoverflow.com/questions/39745663/implementing-checkpointed-interface-snapshotstate-in-flink-is-not-being-calle

这个问题主要的原因是作业已经运行完了，解决方法就是在作业处理方法里面（run回调方法）加一个while死循环，让Flink程序识别作业没有跑完即可。