我有一个用例，它有一个潜在的大映射，我想要在几台机器上分发它的值，以便执行流处理。是否可以使用Apache Flink在集群模式下使用MapState来实现这一点？或者只能在同一台机器的多个线程上并行计算？KeyedStream是否提供了实现这一点的方法？
浏览 16提问于2019-07-17得票数 0
回答已采纳
我即将使用Apache Hadoop，标题如下：分布式系统由多台自治计算机组成，通过计算机网络进行通信。为了达到一个共同的目标，计算机相互作用。
那么，这是否意味着我可以在多台
浏览 9提问于2010-12-15得票数 1
回答已采纳
我有一个带有一个TaskManager和两个处理槽的Apache Flink设置。当我执行一个并行度设置为1的应用程序时，该作业大约需要33秒才能执行。我在我的Windows机器上使用Flink，配置为10个计算核心(4C+ 6G)。我想获得更好的结果与2个插槽。我能做什么?
浏览 22提问于2018-02-26得票数 1
回答已采纳
我正在用Java实现一个Flink程序来处理使用MapStateDescriptor的状态。我是基于这个实现的。由于某些原因，MapState正在持久化以前的值，我无法计算我想要的平均值。import java.util.Map;
import org.apache.flink.api.common.state
浏览 0提问于2019-02-01得票数 0
回答已采纳
我有一个用于处理ProcessWindowFunction的TumblingEventTimeWindows，其中我使用一个状态存储来在多个滚动窗口中保存一些值。我想使用全局状态。我还尝试创建一个最低限度的工作示例来调查这一点：import org.apache.flink.api.common.state.MapStateDesc
浏览 3提问于2020-06-18得票数 0
我正在编写一个Flink应用程序，它使用kafka主题中的时间序列数据。时间序列数据包含指标名称、标记键值对、时间戳和值等组件。我还想检查上面窗口之外是否有任何延迟到达的指标。我想要检查有多少指标延迟到达，并计算与原始指标相比延迟指标的百分比。我正在考虑使用flink的"allowedLateness“功能将延迟指标发送到不同的流。我计划在主"Aggregate the data“操作符中添加一个"MapState”，它将
浏览 17提问于2021-08-09得票数 0
回答已采纳
1回答
我正在开发基于Apache的金融反欺诈系统。我需要根据金融交易来计算许多不同的总和。我使用Kafka作为流数据源。例如，在平均事务量计算中，我使用MapState存储每张卡的总事务数和总金额。聚集数据存储在Accumulo中。我知道Flink中的持久状态，但这不是我所需要的。在计算开始之前，是否有方法将初始数据加载到Flink中？是否可以
浏览 5提问于2017-08-18得票数 1
我可以有多台机器来执行django分发的任务并返回消息吗？我查看了celery/rabbitmq，我不确定是否可以在远程计算机上设置celery工作人员。有人能带我到这里来吗？
浏览 0提问于2012-01-19得票数 2
我在Flink (Java)中创建了一个程序来计算3个不同房间平均9个假传感器。如果启动jar文件，程序运行良好。为什么我不能看到作业在仪表板()上运行，但是如果我看到日志文件(尾-f日志/flink-客户机-*-T430.log)，我可以看到正在处理的东西？此外，print()方法正在将输出溢出到控制台。我使用以下命令./bin/flink run examples/explore-flink
浏览 0提问于2019-02-01得票数 0
回答已采纳
1回答
在我的计算机上，这已经工作了，因为文件已经在那里了。
现在出现了问题，因为我想在多台计算机上运行该程序，因为我需要手动将文件传输到每个工作站，然后运行我的程序。对于一两台计算机来说，这是可以的，因为我可以手工完成，但是如果我有1000台计算机，并且我想在运行程序之前将文件分发给每台计算机，会发生什么呢？在运行实际的MPI程序之前，是否有一种从集群中的主机节点向所有
浏览 6提问于2011-12-06得票数 0
回答已采纳
1回答
该应用程序将需要分发到大约20台计算机，必须是非常友好的用户。我希望有人能解释两件事：到目前为止，我计划使用Java、JavaFX & Microsoft驱动程序。对新想法敞开心扉，提前欢呼。
浏览 3提问于2022-05-03得票数 0
我开始在多台计算机上的反应本机项目。我对本地人的反应相当新鲜，因此可能会有一个新的问题：
为了能够在多台计算机上同步和工作，我需要跟踪的Git文件的最小值是多少？整个文件夹？我是否可以省略特定于平台的构建目录(ios，android)，并让脚本在git pull origin之后重新创建这些
浏览 1提问于2018-06-24得票数 7
回答已采纳
介绍了如何使用Flink对无序流进行排序，但我更愿意使用DataStream API。将使用一个使用PriorityQueue来缓冲事件的ProcessFunction来实现这一点，直到水印表明它们不再是无序的，但是在RocksDB状态后端(问题是每次对PriorityQueue的访问都需要整个无论使用的是哪种状态后端，我如何有效地做到这一点？
浏览 2提问于2019-12-24得票数 5
是否有可能在Greasemonkey脚本之间同步JavaScript对象？我已经创建了一个网站阻止脚本，其中存储了要阻止的网站列表以及允许的网站列表，但我还不知道Greasemonkey是否有任何方法可以在多台计算机上同一脚本的不同实例之间同步这些变量。是否可以同步使用GM_setValue在多台计算机上保存的数据？
浏览 2提问于2013-05-07得票数 1
回答已采纳
我有一个作业jar，它依赖于flink-json-1.7.2.jar，flink-table_2.11-1.7.2.jar。如果我将这两个jars文件添加到flink的lib文件夹中，它就可以在我的本地计算机上正常运行。我怎样才能在我的minikube集群上实现同样的效果。例如，将依赖项添加到flink。Ps。此外，我还可以看到在构建作业jar时创建的fat jar中添加了这些jar。 ?
浏览 23提问于2019-03-11得票数 2
2回答
我试着在集群上运行Dymola，这样我的研究组中的每个人都可以提交模型并模拟作业，是否可以在集群上运行Dymola并利用HPC的功能？我可以用一些旗子使Dymola在多核计算机上并行运行，但是如何在许多计算机上运行并行模拟呢？
浏览 24提问于2021-10-13得票数 0
回答已采纳
我有一个Flink作业，其中一个statefull操作符需要保持一个包含HashMap作为属性的类的状态，因为这个hasMap为用户保留了不同的亲缘关系，例如：*/此hashMap用于跟踪这些亲缘关系，并在特定时刻请求用户的颜色亲和力，并获得最高亲和力值的键，即值9的蓝色。由于hashMaps不是Flink序列化的一部分，所以我需要将implement Seria
浏览 0提问于2020-09-04得票数 2
遗憾的是，公司防火墙不信任NuGet网站，因此PowerShell cmdlet在安装时失败。 我想知道是否可以简单地将包含MSOnline模块的目录从一台PC复制到我的目标PC。
浏览 36提问于2019-05-11得票数 0
我想写一个Flink流操作符，它维护每个键1500-2000个映射，每个映射包含大约100,000个~100B的元素。大多数记录都会触发插入和读取，但我也希望支持整个嵌套映射的偶尔快速迭代。我已经编写了一个为每个键创建1500个由RocksDb支持的MapState的KeyedProcessFunction，并通过生成具有单个不同键的记录流对其进行了测试，但我发现性能很差。class KFP extends KeyedProcessFunction[Int, (Int, String), String] {
var states: Array[
浏览 29提问于2020-08-14得票数 0
回答已采纳
我想在流应用程序中使用KLL sketch。问题是KLL草图是有状态的计算，因此不是幂等的。这是否可以使用在波束或Flink中实现，最好是在Python中？Apache Datasketch说是Integration efforts have started with Apache Flink and Apache Impala.There is also interest from Apa
浏览 12提问于2020-08-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
