Re: PyFlink How to set timeout for UDF

[Dian Fu]

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

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

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!