闪烁的领导选举服务需要处理什么样的争论？
Flink在LeaderElectionService中有以下评论。Java语言
https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionService.java#L26
这个类打算处理什么样的争用？
* Interface for a service which allows to elect a leader among
a group of contenders.
* Prior to using this service, it has to be started calling
the start method. The start method
* takes the contender as a parameter. If there are multiple
contenders, then each contender has
* to instantiate its own leader election service.
共有1个答案
从Flink 1.8开始，有两个类实现了LeaderContaender接口JobManagerRunner和WebMonitorEndpoint需要高可用性，并且需要LeaderElectionService。
public class JobManagerRunner implements LeaderContender,
OnCompletionActions, AutoCloseableAsync {...
public class WebMonitorEndpoint<T extends RestfulGateway>
extends RestServerEndpoint implements LeaderContender, JsonArchivist {...
-
问题内容： 我现在正在编写一个JApplet，每当我调用super.paint（）时，该applet都会闪烁。我正在使用双缓冲（先绘制图像，然后渲染该图像），但我认为super.paint（）正在清除屏幕或其他东西，打败了我的双缓冲。 我知道我应该使用paintComponents（），但是由于某些原因，当我调用“ currentScreen.Draw（g）”时，它不会显示屏幕的绘制。 谁能帮我这
-
我正在开发一个简单的聚合，它对给定资源上发生的事件总数进行汇总（请参阅：在flink中计算总数并定期发射）。在一些人的帮助下，我成功地完成了这项工作，但现在我遇到了另一个问题。 我试图计算资源生命周期的总数，但我正在从保留期为24小时的kinesis流中读取事件。因为这意味着我无法访问在此之前发生的事件，所以我需要从一个每天计算一次总数的遗留（批处理）系统引导我的状态。 基本上，我希望以某种方式从
-
问题内容： 要编译此代码，我可以： 将我的通话置于try / catch块中，或 已经声明它可以抛出一个。 为什么我必须这样做？ （示例代码来自Kathy Sierra的SCJP书 。） 我知道引发的异常是已检查的异常，因此我必须处理它，但是在什么情况下需要引发此异常？ 问题答案： 如果以一种可以引发检查异常的方式声明方法（不是的子类），则调用该方法的代码必须在一个块中调用它，否则调用者方法必须声
-
问题内容： 所以我运行代码，它就开始不正常了。我不熟悉pygame。 代码如下： 这张图片并不是我不能发布视频的那个，但它确实是我的代码的作用 问题答案： 问题是由多次调用 . 在应用程序循环结束时更新显示就足够了。 多次调用or原因 忽隐忽现。 删除对的所有呼叫从你的代码，但调用一次 在应用程序循环结束时： 如果在之后更新显示，将显示在短时间内填充了背景色。然后玩家被抽中 （）显示时，播放器位于
-
问题内容： 我的应用程序中有一个弹出模式服务，名为。它只是在上翻转了一些布尔值，从而导致2条指令正确显示/隐藏。这是显示新模态时调用的函数 如您所见，我显示不透明的背景，然后设置了一个名为的变量，该变量随后通过DI传递到我的指令中。但是后来我注意到我的模态没有出现在适当的时候，而是在变量设置为true 之后出现在NEXT摘要循环中。然后，我必须添加作业周围的内容才能使其正常工作。但是，我认为仅当我
-
null