Flink運行時之合久必分的特定任務

合久必分的特定任務 前面咱們談到了TaskManager對每一個Task實例會啓動一個獨立的線程來執行。在分析線程執行的核心代碼時，咱們看到最終執行的是AbstractInvokable這樣執行體的invoke方法。所謂合久必分，鑑於流處理任務跟批處理任務執行模式上存在巨大的差別，在對AbstractInvokable的實現時，它們將會走向兩個不一樣的分支。java 流處理相關的任務 流處理所對應

>>阅读原文<<