先理解一下你的需求:是说Python UDF的实现,处理一条数据的时间可能非常长,如果很长时间没有执行完,希望作业停止?
> 在 2021年2月3日,下午1:04,苗红宾 <hongbin12...@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! > > > > > > > > > > >