Re: Flink Async io problem

2019-07-09 Thread Yun Gao
Hi Venn, I think `AsyncFunction#asyncInvoke` should be used to submit asynchronous tasks for the input records instead of executing the tasks directly. However, it seems that in the code fragment, the query is executed directly in the asyncInvoke method. I think you may also find mor

Re: Flink Async io problem

2019-07-09 Thread Yun Gao
Hi Venn, I think `AsyncFunction#asyncInvoke` should be used to submit asynchronous tasks for the input records instead of executing the tasks directly. However, it seems that in the code fragment, the query is executed directly in the asyncInvoke method. I think you may also find more

Flink Async io problem

2019-07-09 Thread venn
Hi Flink experts, I’m working flink async io program for stream join outer database(mysql),but found sync,please give some advice, or provide some async demo. thanks asyncInvoke method are as follow: @Override public void asyncInvoke(AsyncUser asyncUser, ResultFuture resultFutur