當使用multiple Executor的時候,有一些場景需要指定Executor來執(zhí)行任務(wù),例如任務(wù)遷移的時候,需要將任務(wù)分配到新加入的Executor來觀察其能夠穩(wěn)定運行,同時在出現(xiàn)問題的時候能夠盡快分配到之前的沒有問題的 Executor來保證任務(wù)的穩(wěn)定運行,因此,需要將任務(wù)分配到指定的Executor上來執(zhí)行。
首先看官網(wǎng):

大概意思就是在 flow params中設(shè)置"useExecutor" = EXECUTOR_ID即可
官網(wǎng)很簡潔,實際具體操作如下:

指定EXECUTOR_ID
EXECUTOR_ID是多少呢?

查看EXECUTOR_ID
如圖所示就是你插入的Executor的ID值。
如果不想通過頁面設(shè)置來指定Executor,可以在properties文件中指定,同時在代碼中加上對該屬性的解析,然后,才能分發(fā)到指定Executor(相信很多公司都已經(jīng)這么做了)。