flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "蒋佳成(Jiacheng Jiang)" <920334...@qq.com>
Subject 回复:1.10任务执行过程--源码的一些疑问
Date Sun, 19 Apr 2020 12:26:40 GMT
在构建MailboxProcessor的时候将streamtask的processInput方法作为MailboxDefaultAction传给了MailboxProcessor。其中的InputStatus
status = inputProcessor.processInput();就是处理数据的地方,比如inputProcessor为StreamOneInputProcessor中InputStatus
status = input.emitNext(output);input为StreamTaskNetworkInput,里面有processElement方法。StreamTask就是AbstractInvokable,StreamTask的invoke()方法调用了runMailboxLoop(),不就是在StreamTask的invoke()中处理的数据吗?



------------------&nbsp;原始邮件&nbsp;------------------
发件人: "祝尚"<17626017841@163.com&gt;; 
发送时间: 2020年4月19日(星期天) 下午5:37
收件人: "user-zh"<user-zh@flink.apache.org&gt;; 
主题: 1.10任务执行过程--源码的一些疑问



Hi,all
在阅读1.10有关job执行过程相关源码时遇到一些疑问,我在看到Task#doRun()方法
invokable.invoke();具体执行过程应该在这个方法里吧?
进一步看了StreamTask#invoke()-&gt;runMailboxLoop();继续往下深入也没发现最终调用udf的入口
问题1:MailboxProcessor、Mailbox、Mail这些概念什么意思,什么作用?

然而在另一处实例化AbstractInvokable时,比如StreamTask构造函数里会调用processInput方法,这个就类似1.9之前的实现方式了
this.mailboxProcessor = new MailboxProcessor(this::processInput, mailbox, actionExecutor);
问题2:这里面是真正的数据处理过程吗?为什么不像1.9之前那样在invokable.invoke()里面做业务处理?
感谢您的答复!


																						
Best,
Sun.Zhu
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message