flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 郑泽辉 <closee...@gmail.com>
Subject Fwd: How to set unorderedWait/orderedWait properties in Table API when using Async I/O
Date Fri, 28 Feb 2020 10:32:46 GMT
---------- Forwarded message ---------
发件人: StevenZheng <closeear7@gmail.com>
Date: 2020年2月28日周五 下午6:30
Subject: Re: How to set unorderedWait/orderedWait properties in Table API
when using Async I/O
To: Danny Chan <yuzhao.cyz@gmail.com>

Thanks Danny and I do run my lookupfunction in a single thread like this
commit:https://github.com/apache/flink/pull/10356, and my customized source
is a jdbc table source.

But actually I still want to know, how to define the return order of async
results and if it is possible to do that.

Danny Chan <yuzhao.cyz@gmail.com> 于2020年2月27日周四 下午9:38写道:

> The lookup event is indeed triggered by the AsyncWaitOperator, the blink
> AsyncLookupJoinRunner is nested into that.
> But we only generates the AsyncWaitOperator when the
> LookupableTableSource#isAsyncEnabled returns true, now only
> InMemoryLookupableTableSource supports that.
> One thing need to note is that you should execute the logic in
> LookupableTableSource with a separate thread if your source is custom.
> So
>    1. What dimension table source do you use ?
>    2. If you customized you source, did you run it in a separate thread ?
> Best,
> Danny Chan
> 在 2020年2月26日 +0800 PM9:14,郑泽辉 <closeear7@gmail.com>,写道:
> Hi all,
> I'm using Blink Planner(flink v1.9) and I create a AsyncJdbcTableSource
> class implements LookupableTableSource, but when I override the
> getAsyncLookupFunction(), I found the results of async method(by Vertx) is
> in order.
> But I don't need the stream order is preserved and just want the result
> records emitted out of order to improve processing speed. In DataStream API
> I can easily set the result order guarantee(
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/asyncio.html#order-of-results),
> and my question is,
> how to set this in Table API or SQL API with Blink Planner?
> Thanks. Regards

View raw message