我需要一个功能，在风暴中，我知道(基于文档)尚未实现。我需要在运行时添加更多的任务，而不需要拥有大量的初始任务，因为这可能会导致性能问题。因为每个executor运行多个任务不会增加并行级别-- executor总是有一个线程用于它的所有任务，这意味着任务在executor上串行运行。我知道rebalance命令可以用来在运行时
浏览 5提问于2017-02-27得票数 0
我试图在运行的Apache (0.9.5)拓扑中重新平衡螺栓的执行器数量。当我对Nimbus节点./storm rebalance MyTopology -n 2 -e GreenBolt=4执行命令时，它接受命令行输入，但是当我在Storm中查看时，执行者的数量不会改变。是否有一个限制，我不知道，就像一个再平衡不能增加总数的执行者，只把他们从一个螺栓到另一个？
浏览 0提问于2015-08-11得票数 1
回答已采纳
我想创建一个拓扑，其中一个喷嘴发出单词，而一个基于这些单词的螺栓创建一个名为word的目录。请建议一种配置storm的方法来实现这一点。
我还想知道，如果一个螺栓是足够的，或者如果部署了两个螺栓，如何管理一个螺栓在一台机器上运行，而在另一台机器上运行。
浏览 3提问于2015-02-22得票数 0
需要帮助调优apache风暴。我已经在nimbus服务器上运行了一个命令来增加喷管执行器&以及一个螺栓。风暴再平衡TopologyName -e喷口/或螺栓=我运行了这个程序，没有看到web界面中的任何变化。还有一种方法可以覆盖storm.yaml文件中的参数吗？
topology.max.spout.pending: 100
浏览 1提问于2015-08-30得票数 0
3回答
在storm中使用“并行提示”来并行化正在运行的storm拓扑。我知道有一些概念，比如工作进程、执行器和任务。让并行度提示尽可能大，以便尽可能多地并行化拓扑是否有意义？我的问题是如何为我的storm拓扑找到一个完美的并行提示数。它是取决于我的storm集群的规模，还是更像是拓扑/作业特定的设置，不同的拓扑会有所不同？或者这取决于两者？
浏览 3提问于2013-12-04得票数 16
回答已采纳
我想知道用什么方法来获取任务信息，而不是执行者信息。我可以做执行者号>任务号，看来任务号是无用的。我已经在getComponentTasks()中使用了Topologycontext，但是我只能得到执行者。
有人能帮我吗？
浏览 11提问于2015-12-16得票数 1
回答已采纳
文档说，默认情况下每个执行器都有一个任务。
如果我有一个“昂贵的”db任务(调用外部dbs需要时间)在螺栓中运行，两边都有“快速”任务，那么我应该为此添加额外的任务吗？
浏览 4提问于2015-06-15得票数 4
回答已采纳
1回答
我正试图通过关注"“这篇伟大的文章来学习推特风暴
然而，我对“任务”的概念有点困惑。任务是组件(喷口或螺栓)的运行实例吗？一个具有多个任务的执行者实际上是说同一个组件被执行器执行了多次，我是正确的吗？此外，在一般的并行性意义上，Storm会为一个喷口或螺栓生成一个专用线程(执行器)，但是具有多任务的执行器(线程)对并行性有什么贡献呢？我认为在一个线程中有多个任务，因为一个线程是按顺序执行的
浏览 3提问于2013-06-23得票数 50
回答已采纳
我一直在探索Apache Storm作为我的一个用例。Spout将从我自己的kafka实现中读取数据，并将其传递给bolts。我怀疑由于这个原因，可能会发生上下文切换，并且由于cpu线程缓存未命中，可能会增加延迟。
我的假设是否</
浏览 4提问于2021-02-17得票数 0
2回答
我正在将apache-storm版本从1.1.1升级到2.0.0。我已经在我的代码库和pom.xml中做了必要的更改。整个项目正在完美地构建，拓扑也开始了，没有任何例外。= -Dstorm.home=/home/user/apps/apache-storm-2.0.0 -Dstorm.log.dir=/home/user/apps/apache-storm-2.0.0&#x
浏览 30提问于2019-07-31得票数 1
回答已采纳
2回答
风暴中的执行者
、、
我有一个关于Storm功能的问题。假设我有一个喷口，它读取一个csv文件，并逐个释放记录。也就是说，它一次发出100个记录到螺栓上。我的问题是，当螺栓接收到一块碎片时，是否只会发送给一个执行者，还是为了并行性而将其分配给不同的执行者。
注:螺栓有5个执行器。
浏览 4提问于2015-07-29得票数 0
回答已采纳
只需阅读更多关于风暴的详细信息，就会发现它能够对字段进行分组，因此，例如，如果您将每个用户的tweet数在哪里，并且您有两个字段分组为用户id，那么相同的用户id将被发送到相同的任务中。因此任务1可以在内存中有以下计数: bob: 10，alice: 5如果我在集群中添加了一台新机器来增加容量并运行重新平衡，那么内存中的计
浏览 6提问于2013-12-07得票数 2
回答已采纳
6回答
我们在伪模式下执行Storm拓扑。但是Storm没有显示正在运行的拓扑信息。
重新启动的暴风UI进程也没有用。是否需要特殊的配置来显示storm中运行的拓扑？
浏览 3提问于2015-02-12得票数 2
回答已采纳
我需要知道Storm如何管理每个螺栓中的并行工作人员的数量。IrichBolt类和IRichSpout类都不实现可运行类。我真的需要知道风暴是如何处理多线程的？
浏览 2提问于2013-11-30得票数 3
回答已采纳
Windows 7
我使用了ParallelOptions()类，这个类的"MaxDegreeOfParallelism“属性设置为5，我在日志文件中记录了"Thread.CurrentThread.ManagedThreadId”，以检查是否在运行时创建了5个线程。我在两个不同的环境中测试了这个应用程序。当应用程序在开发它的环境中运行时，
浏览 4提问于2011-10-28得票数 4
回答已采纳
，如下所示： public abstract addAlgo(Object o); 我希望由不同的人实现不同的Foo，以便在运行时由我的软件动态地保存和运行我有一个主修班如下： Foo f;我希望我的用户在运行时给出他们的Foo实现。我面临以下困难：
如何在Main类
浏览 2提问于2014-05-24得票数 0
我正在尝试使用kubernetes实现TCP/UDP网关，我希望动态地打开和关闭许多端口。containerA之间的连接，我们将提供一个新容器( containerB )，但是使用相同的端口8080，我们将在负载均衡器中添加一个新端口(端口-> 1.1.1.1:9092 -> nginx流9092如果不时添加新端口，然后添加，这种行为是不可取的。
根据我的观察，当向nginx configmap添加一个新端口时，更改将被成功地重新加载，并且端口将被
浏览 2提问于2019-11-27得票数 2
我想要在服务器运行时添加或删除Spring Cloud Gateway路由。我正在使用初始化网关路由。这是完美的工作。但是，现在我想在Spring Cloud Gateway服务器运行时修改、添加和删除路由。我可以看到包含我的路由，但我看不到修改其内容的方法。尽管我在执行器中看到了一些添加功能，但我需要使用代码来添加它们，而不是REST调用。在我的设置中，是空的，所以我看不到<em
浏览 5提问于2020-10-01得票数 0
2回答
我想知道是否有可能创建某种通用的操作/函数列表，每个操作/函数都有不同的输入/输出参数。我需要这样做的原因是，我有一个执行器，它的任务是从API获取数据，该执行器中的每个方法都转到该API中的不同路径，我希望能够调度这些请求，这样我就不会重载该API (如果我超过了它们的请求阈值，它们就会阻塞我因此，每次调用该executer中的方法时，我都会将该方法及其参数添加到一个列表中，另一个线程将在该列表
浏览 2提问于2015-08-16得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
