沉没的 invoke
方法似乎无法制作异步io?例如返回 Future
?
例如,redis连接器使用jedis lib同步执行redis命令:
然后它将阻止flink的任务线程等待来自redis服务器的网络响应命令?!其他运营商是否可以在同一个线程中运行接收器?如果是这样,那么它也会阻止它们?
我知道flink有asyncio api,但似乎没有被sink impl使用?
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/stream/asyncio.html
1 回答
正如@Dexter所提到的,你可以使用
RichAsyncFunction
. 这是一个示例代码(可能需要进一步更新才能使其正常工作;)