flink 任务执行类的加载

执行具体任务的TaskManager在要执行向相应的具体的任务以前,都是经过submitTask()方法获得具体所要执行的任务的。java 在submitTask()中,部署的任务信息并不包含具体所要执行的目标任务类jar包。缓存   所要任务的抽象是Task类。其实现了Runnnable接口,天然提供了run()方法可提供给线程进行调用。在其构造方法中,以自身为target做为Thread构造函
相关文章
相关标签/搜索