Hi！ ExecutionEnvironment 与 StreamExecutionEnvironment 均有 registerJobListener 方法 [1][2]，可以传进一个 JobListener [3]，在作业提交以及完成的时候调用对应方法。当然，这需要你提交作业的客户端程序一直存在，直到作业完成并且对应函数被调用。
[1] https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/api/java/ExecutionEnvironment.html#registerJobListener-org.apache.flink.core.execution.JobListener- [2] https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.html#registerJobListener-org.apache.flink.core.execution.JobListener- [3] https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/core/execution/JobListener.html 陈卓宇 <2572805...@qq.com.invalid> 于2021年12月25日周六 23:30写道： > 您好社区： > 场景是这样的： > > 我司要求将标签数据每日同步一份到mongodb供业务开发同学进行使用，面临这样一个问题，我是不能先删表在建表的，这样会导致接口查询mongodb出现数据查询不到的风险。而是使用切表，将同步表设为:表名_时间戳，将历史表删除，在将同步表改为正确表名，需要flinksql执行完成后触发钩子函数完成切表操作。请问flink有这方面的支持么 > > > > 陈卓 > > >
