小编aff*_*ffo的帖子

在 Flink 中的操作员之间共享状态

我想知道在 Flink 中是否可以在运营商之间共享状态。

例如,假设我在操作符上按键进行分区,并且我需要分A区内的一段分区状态C(出于任何原因)(图 1.a),或者我需要C下游操作符中的操作符状态F(图 1 .b)

在此处输入图片说明

我知道可以broadcast记录到所有分区。因此,如果您在记录中包含操作符的内部状态,则可以与下游操作符共享您的内部状态。
然而,这可能是一个昂贵的操作,而不是简单地让op1具体请求op2状态。

最近围绕可查询状态的发展是否朝着这个概念发展,或者它们只是为了让外部用户查询拓扑的内部状态?

预先感谢您的见解

dataflow stream-processing apache-flink

5
推荐指数
1
解决办法
1498
查看次数

Go(lang)应用程序:Nginx反向代理VS Nginx主机

我已经阅读了有关gonginx的一些问题,但找不到任何答案。

我认为(我不是专家)使用nginx作为net/httpgo服务器之前的反向代理与直接使用nginx托管go应用程序不同。
如果我错了就对我大喊,好吗?

之所以出现这个问题,是因为我需要开发一个应用程序(可能是go,只是为了学习一些新知识),并且要完全控制Web服务器,尤其是要用于响应请求的工作人员数量。

因此,问题来了:

  1. 是否可以直接在nginx上托管go应用程序,还是仅提供静态文件的nginx(如果答案为“否”,那么第二个问题就没有多大意义了)?

  2. 上述两种方法之间的主要区别是什么?确切地说,不同的方法是否会以某种方式影响配置?

  3. 我害怕告诉nginx:“好吧,请使用8个工作器”,什么也不告诉内部网络服务器……会发生什么?

提前谢谢你

nginx go

3
推荐指数
1
解决办法
3936
查看次数

标签 统计

apache-flink ×1

dataflow ×1

go ×1

nginx ×1

stream-processing ×1