我写了一个小的flink应用程序。我有一些输入，并用外部来源的数据来丰富它。这是一个 RichAsyncFunction 而且在 open 方法我构造了一个用于扩展的http客户机。
现在我想为我的工作写一个集成测试。但是由于http客户机是在open方法中创建的，所以我没有办法提供它，并在集成测试中模拟它。我试着在构造函数中重构它，但我总是遇到序列化错误。
这就是我的例子：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/operators/asyncio.html
提前感谢：）