Re: [DISCUSS] Integrate new SourceReader with Mailbox Model in StreamTask

2019-08-12 Thread Becket Qin
+1 as well. starting the work in parallel may also give some insights on whether some additional API on SourceReader is needed in order to support the interaction between SourceReader and runtime. On Mon, Aug 12, 2019 at 11:29 AM Stephan Ewen wrote: > +1 to looking at the Source Reader interface

Re: [DISCUSS] Integrate new SourceReader with Mailbox Model in StreamTask

2019-08-12 Thread Stephan Ewen
+1 to looking at the Source Reader interface as converged with respect to its integration with the runtime. Especially the semantics around the availability future and "emitNext" seem to have reach consensus. On Sat, Aug 10, 2019 at 10:51 PM zhijiang wrote: > > Hi all, > > As mentioned in FLIP-

[DISCUSS] Integrate new SourceReader with Mailbox Model in StreamTask

2019-08-10 Thread zhijiang
Hi all, As mentioned in FLIP-27[1], the proposed SourceReader interface is part of refactoring source interface. AFAIK FLIP-27 has not been voted yet and might still need more time as a whole compared to the SourceReader discussion which seems more or less converged. We would like to start