Flink源码学习（6）StreamTask的初始化和执行

Stream初始化 taskExecutor执行一个Task 当taskExecutor接受提交Task执行的请求，会调用: CompletableFuture<Acknowledge> submitTask( TaskDeploymentDescriptor tdd, JobMasterId jo
posted @ 2024-05-03 12:36  Heinrich?  阅读(13)  评论(0)  编辑  收藏  举报