flink 任務執行類的加載

執行具體任務的TaskManager在要執行向相應的具體的任務以前,都是經過submitTask()方法獲得具體所要執行的任務的。java 在submitTask()中,部署的任務信息並不包含具體所要執行的目標任務類jar包。緩存   所要任務的抽象是Task類。其實現了Runnnable接口,天然提供了run()方法可提供給線程進行調用。在其構造方法中,以自身爲target做爲Thread構造函
相關文章
相關標籤/搜索