我需要使AsyncIO丰富的函数根据最新的规则集执行调用。对于像map这样的操作，我能够通过关注这篇博客文章来处理具有丰富功能的BroadCastConnectedStream：https://flink.apache.org/2019/06/26/broadcast-state.html

但是，创建AsyncIO函数需要数据流作为输入，而BroadCastConnectedStream不需要(https://ci.apache.org/projects/flink/flink-docs-stable/api/java/index.html?org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.html)

有没有人对我如何绕过这个限制有什么想法？场景是，我想要一个异步函数，当对外部世界的异步调用出现非暂时性错误时，将传入消息隐藏在状态中，并在Kafka上收到"继续"消息后恢复操作(我认为我可以用广播流来做这件事)

推荐答案

我认为应该可以将BroadCastProcessFunction(不是键控函数)放在异步I/O操作符之前，但您必须联合正在处理的其他流，因为异步I/O只有一个输入。考虑到这有多难看，寻找其他方式来传达继续前进的信号可能更可取。

或者您可能希望查看Stateful Functions，它在这方面具有更大的灵活性。