我尝试使用元标记在Apache Storm中编写调度器，以将特定任务调度给特定的主管。我在supervisor 1的storm.yaml文件中使用了以下代码： supervisor.scheduler.meta: System.out.println("Your s
浏览 8提问于2020-09-02得票数 0
回答已采纳
1回答
我已经在Apache Storm中修改了现有的Even Scheduler代码。之后，我如何在基准程序上编译和执行此调度器，并检查指标是否有任何更改？必须更改哪些配置文件？请提供一些有帮助的文档，并逐步解释。
浏览 3提问于2019-04-02得票数 0
我按照文档中的说明，在conf/storm.yaml中添加了下面一行
storm.scheduler: “org.apache.storm.scheduler.resource.ResourceAwareScheduler我刚刚从他们的官方网站(二进制版本)下载了Storm的最新版本，我查看了源代码，如果有类存在(它确实存在)，已经启动并运行，我按照给定的指令来启用这个调度器。我可能忘了什么但我完全不知道是
浏览 1提问于2020-06-25得票数 0
我阅读了关于暴风的源代码&&开发人员文档&& JavaDoc &&和其他有用的博客。
一个问题把我弄糊涂了。大多数文档和博客都说，当Storm Cluster将拓扑分配给Workers时，不同的调度器会导致不同的分配风格。但我很困惑，当"org.apache.storm.scheduler.resource.strategies.XXX“分配拓扑时，DefaultResourc
浏览 0提问于2017-12-11得票数 1
嗨，我搜索了这个问题，但没有找到任何令我满意的答案。我打算学习storm，但在此之前，我想知道storm是什么，我们为什么要使用它？在你的项目中使用storm的目的是什么？任何带有示例的解释性答案都将非常感谢，而不是提供到其他网站/问题的链接。
浏览 0提问于2014-10-14得票数 0
1回答
我定义了两个拓扑，并在Nimbus中使用隔离调度器。我已经为我的拓扑分配了下面的配置。但是当Topology-Test2的流量到来时。然后，将所有3个节点重新分配到Topology-Test2。
暴风有可能做到这一点吗？
浏览 4提问于2022-10-09得票数 0
2回答
我需要为每个新员工分配不同的内存值。所以我试着为每一个螺栓和喷口更换记忆。我目前也在使用自定义调度程序。这是我处理这个问题的方法。);我的STORM.YAML- 6703 storm.scheduler: "
浏览 5提问于2016-12-02得票数 4
1回答
Apache和Apache在许多方面是两种截然不同的技术--特别是因为Storm有一个非常具体的用例，而Ignite在一个屋檐下有相当多的工具。据我所知，Ignite的核心是它的内存存储。如果我将滑动窗口设置为一个元组，Ignite提供了类似Storm的一元组实时功能。数据由Ignite存储在内存中。Storm并不是在内存中“存储”数据，但是元组
浏览 4提问于2015-11-26得票数 6
2回答
我有一个数据流，基本上它是一个SQL表，每分钟添加30-50条记录。它需要以接近实时的速度进行处理(记录在数据库中显示后大约在10分钟内处理)。我想在这里使用一些像解决方案这样的工作流，以便更容易地处理所有记录。我需要这个解决方案具有高可用性-系统应该在不同的硬件节点上工作，并在其中一个节点崩溃时具有容错能力。基本上会发生这样的事情：
浏览 2提问于2013-01-15得票数 1
1回答
数据流处理
、、
该图远不是线性的，因为有多个输入以及散开的节点和需要其他几个节点的结果的节点。在所有这些计算中，也可能有几个接收器。然而，没有周期存在。输入节点被更新(不一定一次更新一个)，我让它们的值流经(在这一点上纯粹是概念性的)图。节点在输入更改时保留状态，并且计算必须相对于输入按顺序运行。由于我必须频繁地编写这样的计算，而且我不愿意每次都编写特别的代码，所以我尝试编写一个小的库，以便通过为各种顶点编写类来轻松地拼凑这些计算。然而，我的代码相当
浏览 1提问于2015-11-18得票数 8
1回答
nextTuple()的Storm文档说明如下：
public void nextTuple() { ... Thread.y
浏览 0提问于2018-07-17得票数 1
回答已采纳
2回答
我正在设置一个Apache系统，但在使程序持续运行方面遇到了问题。我已经在三台服务器上设置了风暴，但它只在一台服务器上持续工作。我认为问题就在指挥的道路上。我一直在使用风暴起动器来设置程序，并在本地使用RollingTopWords进行了测试。让我知道，如果有任何其他的信息，我可以提供，这将是有帮助的，因为我感到有点绝望在这一点。
下面是不工作的程序的全部输出。apache
浏览 3提问于2015-06-01得票数 1
我正在尝试更改storm中的wordcount示例:我希望将结果发送到kafka集群而不是显示结果。这是构建拓扑的代码： config.setDebug(true);at org.apache.storm.tuple.TupleImpl.getValu
浏览 0提问于2017-11-03得票数 0
我正在由两个节点组成的Storm集群中运行wordcount拓扑。一个节点是主节点(带有Nimbus、UI和Logviewer)，然后这两个节点都是主管，每个管理员都有一个工作人员。详细地说，拓扑有一个有两个线程的喷出，一个分裂螺栓和一个计数螺栓。当我使用默认调度程序部署拓扑时，第一个主管有1个Spout线程和split，第二个主管有一个Spout线程和count。在这种情况下，我如何控制这2名工人之间的操作人员(Spout/Bolt)的安置？为了研究目的，我
浏览 0提问于2020-02-04得票数 0
2回答
我是storm和zookeeper的新手，我导入了项目，想知道编码器使用的zookeeper版本！正如他提到的那样，他使用了storm-0.8.2，但没有提到zookeeper
是否知道他从项目的特定文件夹中使用的zookeeper版本？
浏览 0提问于2015-12-02得票数 0
回答已采纳
在运行风暴拓扑以读取Kafka主题并将数据写入Hive表时，我正在获取IllegalAccesserror :错误详细信息如下所示：我的风暴拓扑代码： public static final String KAFKA_SPOUT_ID = "kafka-spoutversion>0.0.1-SNAPSHOT</ver
浏览 19提问于2016-03-19得票数 4
我对maven和storm非常陌生，所以我尝试遵循中的说明。我目前的路径是/home/luc/theTest/storm/examples/storm-starter.在目标文件夹中有一个starter 2.0.0-SNAPSHOT.jar文件。我在跑步的时候被困住了
风暴jar目标/风暴-启动器-*.jar org.apache.storm.starter.Exclamation
浏览 9提问于2017-10-28得票数 2
回答已采纳
1回答
我目前正在做一个用例(用Java，Spring开发)，其中我有很大的不同。%的twitter帐户(第帐户的数量可以达到数千个)，我可以在配置/计划时发布数据(推文)。我已经实现了将数据发布到twitter上，但我对如何从各种twitter账户中提取印象/转发和喜欢的推文感到困惑。一种解决方案是定期轮询所有账户，但在这种情况下，我不会在推文上得到任何点赞，因为我使用的是用户，并提到了带有"since_id“参数的时间线API
浏览 1提问于2017-05-02得票数 0
我已经在元数据中添加了一个字段，用于在状态索引中传输和持久化。该字段是字符串列表，其名称为 输入 _ 关键词 ..。(DisruptorQueue.java:487) ~[storm-core-1.2.1.3.1.4.0-315.jar:1.2.1.3.1.4.0-315] at org.apache.storm.disruptor$consume_loop_STAR_$fn__413
浏览 186提问于2021-02-28得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
