当前位置: 首页 > 知识库问答 >
问题:

Flink是否以高效的方式创建频道?

毛德曜
2023-03-14

我检查apache Flink代码如何创建连接客户端:https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java#L55-L108

我正在考虑2秒后超时的waitForChannel()方法:https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java#L191

我不喜欢这个超时,我认为如果发生错误分区Request estClient到达通知所有()就足够了。

我说得对吗?还是我们想在等待2秒钟后不断尝试连接?

共有1个答案

司徒正信
2023-03-14

实际上,我们并没有在等待后尝试(重新)连接,我们只是重新进入循环以检查情况,并将在任何连接锁(connectLock)出现时立即醒来。notifyAll()调用也在超时结束之前执行。

通常,这也会让您有机会在永远不会有此类通知的情况下做出反应,但正如上文所述,我实际上没有看到任何其他可能导致循环之外的地方。

 类似资料:
  • 问题内容: 是否有免费的库可根据图像序列创建MPEG(或任何其他简单的视频格式)? 它也必须在Linux上运行,并且最好具有Python绑定。 问题答案: 我知道有一个mencoder(是mplayer项目的一部分)和ffmpeg,它们都可以做到这一点。

  • 问题内容: 是否可以创建内联伪样式? 例如,我可以做以下事情吗? 这背后的原因是我正在开发一个创建UI元素的.NET库。我想生成无需设置外部样式表即可设置其悬停状态的HTML元素。 问题答案: 不幸的是,不能,您不能使用内联CSS来实现悬停效果。 此问题的(较差)解决方法是让控件在呈现时呈现样式块。例如,您的控件可以呈现为: 如果您可以强迫用户在页面顶部放置“样式控件”,则可以在其中渲染所有自定义

  • 我想创建一个应用程序,它可以将屏幕行为记录为视频,并以编程方式保存在设备上。有人能帮我吗?

  • 在Android/Java中,是否有任何代码示例以编程方式捕获具有每秒良好帧的计算机的屏幕截图并创建视频? 我想要一个教程或完整的源代码来做到这一点。我希望该程序可以使用设备,而无需“植根”设备。 播放商店中有一个名为”的应用程序可以执行此操作。但是您需要ROOT设备才能使其正常工作,因此我知道这是可以做到的。 在无root设备上捕获Android屏幕截图并以编程方式创建视频的最佳方法是什么?

  • 问题内容: 谁能解释Java如何执行此代码?我的意思是执行每个语句的顺序。 输出: 问题答案: 类初始化开始。最初为null,为false 第一个静态变量初始值设定项()运行: 创建了一个新实例 用于执行的实例变量初始值设定项-当前为false,因此值为false 执行第二个静态变量初始化器(),将值设置为true 类初始化完成 运行,打印出,这是错误的 请注意,如果声明为,则将其视为 编译时常量

  • 问题内容: 我一直在尝试以编程方式重做我的应用程序上的工作。(不使用情节提要) 除了手动制作导航控制器外,我几乎完成了。 我一直在做一些研究,但找不到任何手动实现此方法的文档。(我开始将应用程序制作为单视图应用程序) 目前,我只有1个ViewController。当然是appDelegate 导航控制器将在应用程序的所有页面中使用。 如果有人可以帮助我,或发送指向一些适当文档的链接以编程方式进行此