我在Flink上做了一些延迟和吞吐量的测试。我正在测量Flink集群中记录的平均延迟和吞吐量。我正在查看缓冲区超时配置。我注意到Flink建议避免0毫秒的超时；但是，我注意到即使在大量消息负载的情况下，性能也没有严重下降。将此值降低到零的缺点是什么？我知道这可能很激进，但我真的很好奇这种设置对性能的影响。提前谢谢你。
浏览 51提问于2020-06-30得票数 0
1回答
如何在Flink中传递配置？我尝试过在flink-conf.yaml中添加这个配置，但是它没有工作。我们需要在哪里设置这个配置？StreamExecutionEnvironment env = StreamExecutionEnvironment.createRemoteEnvironment更新
为
浏览 4提问于2021-04-14得票数 0
当我用KeyedStream运行一个简单的flink应用程序时，我观察到事件的时间延迟从0到100ms不等。l; } env.execute(); 输出为：in Sink: diff=0in Sink: diff=4in Sink:
浏览 53提问于2019-06-30得票数 0
回答已采纳
在我的Flink应用程序中，我使用java.time.Instant来表示UTC时间戳。有关对性能的影响的详细信息，请阅读\”数据类型和序列化\“上的Flink文档。”
当我去阅读文档时，没有太多关于使用像Instant这样的东西对性能的影响的讨论。我一般的理解是，必须使用Kryo而不是Flink内置的
浏览 93提问于2020-02-05得票数 0
回答已采纳
1回答
Flink文档表明Ceph可以用作状态的持久存储。
考虑到Ceph是一个事务性数据库，它不会对Flink的性能产生不利影响吗？
浏览 6提问于2017-12-05得票数 3
回答已采纳
4回答
如果还没有实例化，我有一个可能为null的列表，我希望在调用GetList()时能够返回现有的列表或创建列表，然后返回。new List<object>();}
但是，在将列表设置为自身时是否存在性能问题，或者C#是否意识到这是不必要的？
浏览 8提问于2015-09-10得票数 2
回答已采纳
我们的一些POJO包含来自java.time接口(LocalDate，LocalDateTime)的字段。当我们的管道处理它们时，我们可以在日志中看到以下信息：
org.apache.flink.api.java.typeutils.TypeExtractor - Class class java.time.LocalDate据我所知，LocalDate不能归类为POJO，所以flink不使用POJO序列化程序，而是使用Kryo，效率较低。然而，从1.9.0版本开始，flink<
浏览 240提问于2021-02-17得票数 1
回答已采纳
我们使用的是kafka 0.10.2.1。文档指定，即使缓冲区不是满的，也可以发送-
请注意，即使使用linger
浏览 0提问于2018-03-16得票数 14
回答已采纳
2回答
我计划将Flex应用程序上的所有控件(超过100个可见)设置为低于1的alpha，这将使它们变得有点透明，但我想知道这是否会影响应用程序的性能。因此：
I想知道alpha是否真的会影响Flex应用程序的性能?
浏览 2提问于2011-06-12得票数 0
回答已采纳
在我将一些遗留代码从win32移植到win64之后，在讨论了删除警告“可能丢失数据”()的最佳策略之后。我将在代码中用size_t替换许多size_t。但是，我的代码在性能方面是至关重要的(我甚至不能在Debug...too慢速运行它)。}Elapsed 2185ms为x86编译，它输出：Elapsed 2748ms</
浏览 0提问于2016-05-03得票数 4
回答已采纳
背景:我正在使用TFX管道，并使用Flink作为光束的运行器(使用flink-on-K8s-operator的flink会话集群)。Flink集群有2个任务管理器，每个任务管理器有16个核心，并行度设置为32。TFX组件调用beam.io.ReadFromTFRecord来加载数据，传入一个glob文件模式。我有一个跨160个文件的TFRecords数据集。当我尝试运行该组件时，对所有160个文件的处理在Fl
浏览 18提问于2021-09-20得票数 0
回答已采纳
2回答
降低我的应用的部署目标
、、、
我在iOS 7.1中创建了我的通用设备游戏应用，并在那里将我的部署目标设置为7.1。我目前使用的是7.1和8.1iphone/iPad两个iOS版本的模拟器。如果我将部署目标设置为iOS 6.1或7.0，是否会对游戏性能产生影响？如果我将其设置为低于7.1，是否会产生负面影响
浏览 4提问于2014-12-16得票数 1
1回答
Flink保存运算符的托管状态(用于检查点或逻辑运算符之间的通信(即沿作业图的边缘))是什么格式？背景:我正在考虑从JSON切换到使用AVRO，既可以将中的数据摄取到我的源中，也可以由向我的Sinks发送数据。然而，由
浏览 4提问于2017-12-21得票数 2
回答已采纳
我在读书启用检查点:如果启用了检查点，则Flink消费者将在检查点完成时提交存储在检查点状态中的偏移量。这确保了Kafka代理中提交的偏移量与检查点状态中的偏移量一致。请注意，在此场景中，属性中的自动周期性偏移提交设置将被完全忽略。如果我在10秒间隔内启用检查点，也可以将have setCommitOffsetsOnCheckpoints设置为tru
浏览 0提问于2021-06-25得票数 0
回答已采纳
1回答
我们在所有linux机器上将MTU设置为9000 (我们有红帽子机器版本- 7.3 )，linux机器是hadoop集群的一部分。
我们想知道是否将MTU设置为9000对操作系统性能有负面影响？是否将其他Jumbo帧值设置为MTU=8000或更少/更多，对于操作系统性能会更好吗？
浏览 0提问于2018-03-06得票数 0
回答已采纳
1回答
我很难理解纱线容器是如何受限于分配的资源的，尤其是CPU。据我所知，YARN会监控内存使用情况，如果容器超出了限制，它会发送一个kill信号。我想知道CPU调度到底是如何工作的。我在纱线容器(1CPU)中的JVM作业可以尝试创建多个
浏览 2提问于2021-12-02得票数 0
在我看来，大多数时候你会希望在你的a4j:support，a4j:commandLink，a4j:commandButton等组件上将ignoreDupResponse设置为true。在哪种情况下，将ignoreDupResponse设置为false会很有用？将ignoreDupResponse设置为true是否会对性能造成影响？如果不是，为什么
浏览 3提问于2010-10-13得票数 1
回答已采纳
如果将IIS7中的应用程序池设置为启用32位，是否会影响性能。任何关于这方面的博客或文章，或者任何人都有过这样的经历。
问候
浏览 0提问于2010-08-05得票数 4
据我目前所读，使用丢弃或更改片段着色器内的深度值将禁用早期深度测试，从而降低着色器性能。现在，我已经有了一个应用程序，使用丢弃只会产生轻微的影响，但是改变深度值会严重降低性能： (增加点大小，如果速度太快的话放大)
将质量设置为“圆圈”将称为丢弃，以便将点呈现为圆圈。将质量设置为“插值”将改变片段深度值。我
浏览 2提问于2015-07-02得票数 1
回答已采纳
我的主要问题是，在单个表中，WHERE子句中未包含的记录数量是否会影响SELECT、INSERT和UPDATE的查询性能
假设我有一个有2000万行的表，并且这个表有一个索引的error字符串列。假设这些记录中有19,950,000条为该列设置了0，其中50,000条记录的值设置为NULL。在我的</e
浏览 11提问于2017-03-08得票数 1
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
