当使用multiple Executor的时候,有一些场景需要指定Executor来执行任务,例如任务迁移的时候,需要将任务分配到新加入的Executor来观察其能够稳定运行,同时在出现问题的时候能够尽快分配到之前的没有问题的 Executor来保证任务的稳定运行,因此,需要将任务分配到指定的Executor上来执行。
首先看官网:
大概意思就是在 flow params中设置"useExecutor" = EXECUTOR_ID即可
官网很简洁,实际具体操作如下:
指定EXECUTOR_ID
EXECUTOR_ID是多少呢?
查看EXECUTOR_ID
如图所示就是你插入的Executor的ID值。
如果不想通过页面设置来指定Executor,可以在properties文件中指定,同时在代码中加上对该属性的解析,然后,才能分发到指定Executor(相信很多公司都已经这么做了)。