Re: Beam support Flink Async I/O operator

2021-01-27 Thread Eleanore Jin
ha, yes, sorry I forgot about that On Wed, Jan 27, 2021 at 4:31 AM Alexey Romanenko wrote: > I guess it was already discussed a while ago [1] and the conclusion was > that Flink Async I/O is a specific Flink operator and it can’t be used > directly from Beam since Beam should provide a unified m

Re: Beam support Flink Async I/O operator

2021-01-27 Thread Alexey Romanenko
I guess it was already discussed a while ago [1] and the conclusion was that Flink Async I/O is a specific Flink operator and it can’t be used directly from Beam since Beam should provide a unified model and its implementation for all supported runners. Did a proposed workaround, based on Group

Re: Beam support Flink Async I/O operator

2021-01-26 Thread Boyuan Zhang
+dev On Tue, Jan 26, 2021 at 1:07 PM Eleanore Jin wrote: > Hi community, > > Does Beam support Flink Async I/O operator? if so, can you please share > the doc, and if not, is there any workaround to achieve the same in Beam > semantics? > > > https://ci.apache.org/projects/flink/flink-docs-stab