MailboxProcessor、Mailbox、Mail这些概念什么意思，什么作用？
在阅读1.10有关job执行过程相关源码时遇到一些疑问，我在看到Task#doRun()方法 invokable.invoke();具体执行过程应该在这个方法里吧？ 进一步看了StreamTask#invoke()->runMailboxLoop();继续往下深入也没发现最终调用udf的入口 问题1：MailboxProcessor、Mailbox、Mail这些概念什么意思，什么作用？
然而在另一处实例化AbstractInvokable时，比如StreamTask构造函数里会调用processInput方法，这个就类似1.9之前的实现方式了 this.mailboxProcessor = new MailboxProcessor(this::processInput, mailbox, actionExecutor); 问题2：这里面是真正的数据处理过程吗？为什么不像1.9之前那样在invokable.invoke()里面做业务处理？ 感谢您的答复！*来自志愿者整理的FLINK邮件归档
写回答
-
invokable 一般是 StreamTask 或者它的子类 StreamSourceTask，具体的 UDF 在 StreamTask 里，有几层包装。
MailBox 那些其实是一个简单的 EventLoop 实现，或者你理解为 Actor Model 的实现也行，可以参考这些名词的解释文章一一对应。*来自志愿者整理的FLINK邮件归档
2021-12-03 18:51:30赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
