与多个TaskManager共享同一密钥
我有一个运行在400个TaskManager上的flink应用程序。在1小时的窗口时间内，我会更频繁地获得相同的密钥，比如说，在1500个唯一密钥中，有50个密钥会更频繁地出现。这使得很少有任务管理者单独处理的数量比其他人多。如果390个TaskManager每分钟处理50MB，那么其他10个TaskManager每分钟处理10GB。这使得系统速度非常慢。如果负载很高，我们可以与多个TaskManager共享同一个密钥吗。我怎样才能在这里解决我的问题。
共有1个答案
如果您想要对数据进行更细粒度的分区，您需要找到一种对当前键进行细分的方法。根据您正在做的事情，在聚合当前键级别之前添加预处理层可能是有意义的（例如）。
-
问题内容： 我有多个具有相似构建步骤的项目，并且我正在研究在这些项目中重用Jenkinsfile管道。我很难找到有关如何实现这样的标准（我认为）设置的文档。 这是我的要求： 1）Jenkinsfile存储在回购中，在多个项目之间共享 2）每个项目都有其自己的参数：项目在仓库中的位置。 3）至少从用户角度来看，每个项目在Jenkins中都应独立，这意味着，例如，执行和日志可在Jenkins中的每个项
-
问题内容： 我正在尝试建立一个共享库。让我们说libabc.so。它使用另一个.so文件，例如lib123.so（/ usr / local / lib中的一个lib）。现在我在我的应用程序中使用共享的liblibabc.so。说我的应用程序。我想知道我应该如何链接这些二进制文件？我不想直接将我的应用程序与lib123.so链接。my- app应该仅与libabc.so链接。我怎样才能做到这一点？
-
需要在给定的64字节公钥（他们的）和32字节的私钥（我们的）之间共享秘密。 我有由外部提供商生产的密钥（P-256 ECC代码）。公钥为 64 字节，私钥为 32 字节。 我不知道如何让BouncyCastle导入这些密钥。它似乎期望DER编码的密钥，但这不是我必须使用的。 我的期望是加密/密钥代码可以处理32和64字节的密钥数组。在处理嵌入式设备和其他代码空间有限的领域时，无法处理包装/DER/
-
我使用jsPlumb允许用户构建图形。我允许用户拖动这些元素，所以我为每个endpoint使用锚集合，让jsPlumb在建立连接时从该集合中为我选择“最佳”锚。我遇到的问题是，我可能有多达十几个连接来自任何给定的endpoint，所以当许多人最终选择相同的“最佳”锚点时，这些连接将在视觉上分散注意力——在图中造成拥塞的外观。为了解决这个问题，我想告诉jsPlumb限制任何两个连接在endpoint
-
问题内容： 我想像这样在多个线程之间共享一个变量： 我想在主线程和帮助线程之间共享，这是我创建的两个不同的Java类。有什么办法吗？谢谢！ 问题答案： 二者并可以参照包含该变量的类。 然后，可以使该变量为 volatile ，这意味着 对该变量的更改在两个线程中立即可见。 有关更多信息，请参见本文。 易变变量 共享已同步的可见性功能，但不共享原子性功能。这意味着线程将自动 查看volatile变量