Hi, all. The invoke method of sink seems no way to make async io? e.g. returns Future?
For example, the redis connector uses jedis lib to execute redis command synchronously: https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java Then it will block the task thread of flink waiting the network response from redis server per command?! Is it possible for other operators running in the same thread with sink? If so, then it would block them too? I know flink has asyncio api, but it seems not for used by sink impl? https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/stream/asyncio.html Thanks.
