我有几个使用akkahttp的库,用于处理大量数据的io。现在。我有一个flink应用程序,在那里我需要使用那些库。
如何在我的flink应用程序中使用公共演员系统?我的意思是,afaiu、flink应用程序将被分发,同样的管道最终可能会在多个jvm上创建多个参与者系统。同样,同一个jvm也可以在多个管道之间共享,在这种情况下,拥有多个参与者系统意味着拥有大量线程。
我认为这是个问题,对吗?如果是这样,我怎样才能避免这个问题?更具体地说,有没有一种方法可以在同一个jvm上的应用程序之间共享actor系统?我知道flink有办法使用异步io获得相同的执行上下文。
暂无答案!
目前还没有任何答案,快来回答吧!