在我的应用程序中，我想丰富无限的事件流。流本身通过散列id进行并行化。对于每个事件，可能会调用外部源（例如rest、db）。这个电话是天生的阻塞。必须保持一个流分区内事件的顺序。
我的想法是创建一个richmapfunction，它设置连接，然后为每个事件轮询外部源。阻塞呼叫通常不会花费太长时间，但在最坏的情况下，服务可能会中断。
理论上，这是可行的，但我不觉得这样做很好，因为我不知道如果流中有一些阻塞操作，flink会有什么React。如果有大量并行流阻塞，会发生什么情况，即线程用完了吗？或者行为流是如何在平行点向上的？
是否有其他人可能有类似的问题和我的问题的答案或一些想法如何解决它？