??????1.10????????????--??????????????

[??????(Jiacheng Jiang)]

??????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()????????????????



------------------ ???????? ------------------
??????: "????"<17626017...@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