You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 苗红宾 <ho...@126.com> on 2021/02/03 05:04:18 UTC

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!

Re: PyFlink How to set timeout for UDF

Posted by Dian Fu <di...@gmail.com>.

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

> 在 2021年2月3日，下午1:04，苗红宾 <ho...@126.com> 写道：
> 
> 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!
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
>