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
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
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