flink批处理 - flink吧

level 1

薄冰222 楼主

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

2019年12月05日 08点12分 1