我想知道在 Flink 中是否可以在运营商之间共享状态。
例如,假设我在操作符上按键进行分区,并且我需要分A区内的一段分区状态C(出于任何原因)(图 1.a),或者我需要C下游操作符中的操作符状态F(图 1 .b)
我知道可以broadcast记录到所有分区。因此,如果您在记录中包含操作符的内部状态,则可以与下游操作符共享您的内部状态。
然而,这可能是一个昂贵的操作,而不是简单地让op1具体请求op2状态。
最近围绕可查询状态的发展是否朝着这个概念发展,或者它们只是为了让外部用户查询拓扑的内部状态?
预先感谢您的见解
我已经阅读了有关go和nginx的一些问题,但找不到任何答案。
我认为(我不是专家)使用nginx作为net/httpgo服务器之前的反向代理与直接使用nginx托管go应用程序不同。
如果我错了就对我大喊,好吗?
之所以出现这个问题,是因为我需要开发一个应用程序(可能是go,只是为了学习一些新知识),并且要完全控制Web服务器,尤其是要用于响应请求的工作人员数量。
因此,问题来了:
是否可以直接在nginx上托管go应用程序,还是仅提供静态文件的nginx(如果答案为“否”,那么第二个问题就没有多大意义了)?
上述两种方法之间的主要区别是什么?确切地说,不同的方法是否会以某种方式影响配置?
我害怕告诉nginx:“好吧,请使用8个工作器”,什么也不告诉内部网络服务器……会发生什么?
提前谢谢你