PyFlink How to set timeout for UDF

[苗红宾]

Hi：

Hope you are doing well!

My UDF always running in a long time, so I'm wondering, how to set timeout for UDF in Pyflink, in order to auto-stop the execution when it running in a long time.

Many Thanks!





 





 

[Dian Fu]

先理解一下你的需求：是说Python UDF的实现，处理一条数据的时间可能非常长，如果很长时间没有执行完，希望作业停止？

> 在 2021年2月3日，下午1:04，苗红宾 <[hidden email]> 写道：
>
> Hi：
>
> Hope you are doing well!
>
> My UDF always running in a long time, so I'm wondering, how to set timeout for UDF in Pyflink, in order to auto-stop the execution when it running in a long time.
>
> Many Thanks!
>
>
>
>
>
>
>
>
>
>
>