Flink运行时之合久必分的特定任务

合久必分的特定任务 前面咱们谈到了TaskManager对每一个Task实例会启动一个独立的线程来执行。在分析线程执行的核心代码时,咱们看到最终执行的是AbstractInvokable这样执行体的invoke方法。所谓合久必分,鉴于流处理任务跟批处理任务执行模式上存在巨大的差别,在对AbstractInvokable的实现时,它们将会走向两个不一样的分支。java 流处理相关的任务 流处理所对应
相关文章
相关标签/搜索