Hi Sharon, I think for DataStream API, you can override the isEndOfStream() method in the DeserializationSchema to control the input data source to end and thus end the workflow.
Thanks, Fuyao From: Sharon Xie <sharon.xie...@gmail.com> Date: Monday, October 11, 2021 at 12:43 To: user@flink.apache.org <user@flink.apache.org> Subject: [External] : Timeout settings for Flink jobs? Hi there, We have a use case where we want to terminate a job when a time limit is reached. Is there a Flink setting that we can use for this use case? Thanks, Sharon
