Hi all, I set up a job with simple queryable state sink and tried to query it from another job using the new Async I/O API. Everything worked as expected, except when I tried to increase the parallelism of the querying job it hanged. As you can see in the attached image, when the parallism is 5 (even <5) the job finishes within 5 seconds, but when it is >5 it hangs. Any Idea of what might be causing this behaviour? Thank you.
Best, Yassine
