我有份工作。完成后，我想触发一个外部服务。尝试使用joblistener api，但似乎没有执行我的处理程序。我们正在运行flink 1.11的Yarn（分离模式）。
在流式api中，我会尝试使用计时器来完成它（max\u水印表示输入结束）。但我们宁愿和巴奇呆在一起。