Hi, Boot. For DirectedOutput, I guess you want to split stream. For splitting stream, you can use side_output[1]
[1]: https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/side_output/ Best regards, Yuxia ----- 原始邮件 ----- 发件人: "Boot" <331233...@qq.com.INVALID> 收件人: "dev" <dev@flink.apache.org> 发送时间: 星期一, 2022年 5 月 16日 下午 5:59:17 主题: Fw: What is the alternative schema of DirectOutput The correct class name is DirectedOutput ---Original--- From: "Boot"<331233...@qq.com> Date: Mon, May 16, 2022 17:19 PM To: "user"<u...@flink.apache.org>; Subject: What is the alternative schema of DirectOutput Hi, Could you do me a favor plz? I wonder if the DirectOutput class which works in version 1.11 is removed in version 1.15. If so, Could you tell me why and what is the alternative solution? Thank you!