各位大佬好,请教一个问题。 我根据ResourceID主动释放TM的链接的时候,我发现TM对应的Slots仅仅是标记为free。 而其真正是释放却要等到JobMaster主动cancel整个ExecuteGraph的时候,此时会逐个调用每个定点所在的slot的TM的cancel方法。 但是此时相关联的TM已经close掉,触发了rpc超时,默认20s。然后slot才会被释放。
我的问题是:为什么不在调用TaskExecutor的cancelTask之间判断下TM是否存活,如果不存活就直接走cancel的流程,不用等rpc超时后,才进行下一步??? 附上日志截图: | | johnjlong | | johnjl...@163.com | 签名由网易邮箱大师定制