1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答1、在一个TaskManager中可能要执行多个Task，如果多个Task的数据最终都要传输到下游的同一个TaskManager就会复用同一个Socket进行传输，这个时候如果单个Task产生反压，就会导致复用的Socket阻塞，其余的Task也无法使用传输，checkpoint barrier也无法发出导致下游执行checkpoint的延迟增大。2、依赖最底层的TCP去做流控，会导致反压传播路径太长，导致生效的延迟比较大。2024-06-15 15:20:28赞同 2 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
