大佬好，我用Flink做批处理，怎么得知这个批处理已经结束了？我是对env.execute()做try catch，本地测试有效，集群跑的话没反应，请问怎么回事？我目的是想在批处理结束后通知我，比如发封邮件，调一下web接口，困扰我好几天了谢谢教我一下。