Re: PyFlink How to set timeout for UDF

2021-02-03 文章 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

PyFlink How to set timeout for UDF

2021-02-02 文章 苗红宾
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!