Submitter和Cluster之间有什么特别的区别吗？当我使用LocalCluster时，它会自动创建一个yaml文件。但是，我想用我自己的设置来设置这个yaml文件。
浏览 18提问于2018-09-03得票数 0
回答已采纳
我正在尝试向我的风暴集群提交一个单词计数拓扑。我使用Eclipse创建了一个jar，但它显示了异常。 } public void declareOutputFields(OutputFieldsDeclarer declarer) {}主类创建拓扑word-normalizer");
//To
浏览 4提问于2015-04-14得票数 1
回答已采纳
2回答
我已经在我的机器上配置了Storm。Zookeeper、Nimbus和Supervisor运行正常。现在我想向这个storm提交一个拓扑。我正在尝试使用storm jar。但是我不能提交它。
浏览 1提问于2013-09-19得票数 7
回答已采纳
我按照给出的指令在1台机器上设置了一个风暴节点令我惊讶的是，他们仍然在汇编和运行，好像什么都没有改变一样。为了确保进程被终止，我关闭了我的计算机并重新启动它。我是风暴和分布式系统的新手。
浏览 5提问于2014-06-12得票数 2
回答已采纳
我确信动物园管理员、nimbus、主管和ui服务都在正常运行，因为我可以看到这些进程，也可以从浏览器中查看UI。暴java代码可以像预期的那样在eclipse中运行，您可以引用下面的代码来找出本地模式和远程模式的不同之处。1797 main INFO o.a.s.s.a.AuthUtils - Got []线程"main“java.lang.RuntimeException中的异常: org.apache.storm.StormSub
浏览 2提问于2016-08-30得票数 0
我在ubuntu 12.04上运行storm和rabbitmq。rabbitmq正在发送由storm spout接收的数据。我使用StormSubmitter类来指定一个集群。我正在使用command> bin/storm jar Rabbitmqstorm.jar RabbitmqTopology rabbittest来运行storm拓扑。但是我在线程"main“java.lang.NoC
浏览 0提问于2014-04-07得票数 1
我已经开发了一个应用程序来使用apache来使用kafka消息，当我运行LocalCluster中使用的拓扑时，它工作得很好，消息可以正常使用，但是当我使用(bin\storm jar .\kafka- storm -0.0.1-SNAPSHOT.jar com.kafka_storm.util.Topology )运行这个命令时，这个拓扑开始了，但是无法使用任何
浏览 0提问于2018-06-17得票数 0
这是我第一次使用Apache，我有以下问题。对于我的应用程序，我有这样的要求:对于使用我的应用程序的每个用户来说，拓扑图是不同的，而且每个用户也可以有多个拓扑图。因此，我的想法是使用拓扑生成器动态创建拓扑图。例如，使用“风暴”中的图例，只需：
builder.set
浏览 3提问于2015-11-29得票数 1
回答已采纳
2回答
我采用了示例字数统计代码，并尝试在不提交到LocalCluster.的情况下提交到远程nimbus服务器。我在客户端使用了以下代码，并使用了以下yaml配置，服务器和ZK分别启动。当我在客户端使用下面的代码提交时，当我运行.)at org.apache.th
浏览 0提问于2014-12-04得票数 4
1回答
，这个问题得到了“解决” 59297 [Thread-14] ERROR o.a.s.d.s.ReadClusterState - Failed to Sync Supervisor 下面是我的自定义拓扑Config config = new Config(); config.setNumWorkers(1);
浏览 38提问于2019-05-18得票数 2
回答已采纳
1回答
风暴创建拓扑
、、
我正在尝试使用Eclipse在Linux中运行storm starter示例。我收到以下错误，并且从未调用过nexttuple函数。:1.7.0_67]我的拓扑类：
浏览 2提问于2016-04-14得票数 0
1回答
我是apache和kafka的新手，我试着通过OpenClassroom.The原理提供的课程来学习这些概念，通过python程序将消息发送到kafka服务器，并通过storm拓扑的主类中定义的kafka据我所知，这是在ParsingBolt类中使用以下代码行完成的：JSONObject obj = (JSONObject)jsonParser.parse(input.getStringByField(唯一的问题是，我不明白我们如何知道消息包含在value字段中
浏览 21提问于2022-06-13得票数 0
回答已采纳
2回答
我正在设置一个Apache系统，但在使程序持续运行方面遇到了问题。我已经在三台服务器上设置了风暴，但它只在一台服务器上持续工作。我认为问题就在指挥的道路上。我一直在使用风暴起动器来设置程序，并在本地使用RollingTopWords进行了测试。jar存储在目录/apache/storm/examples/starter/target中。让我知道，如果有任何其他的信息，我可以提供，这将是
浏览 3提问于2015-06-01得票数 1
下面的设计可以在Storm中完成吗？如果我有两个文件file1和file2，其中一个应该能够调用相同的拓扑，并创建该拓扑的两个实例来运行相同的字数统计。在我们对拓扑发出kill命令之前，它们一直都是活着的我知道，在流媒体世界中，消息来自Kafka这样的消息队列，消息没有结尾，但在实
浏览 1提问于2015-12-23得票数 0
4回答
是否有一种简单的方法可以在本地机器(Ubuntu12.4LTS vm)上部署Apache storm以供评估之用？
浏览 3提问于2014-04-02得票数 2
回答已采纳
我有一个使用Apache storm创建的拓扑。我已经在适当的地方创建了不同的螺栓和喷嘴来执行各种活动。然而，我计划创建一个自动化测试套件来测试拓扑的功能。目前，我的拓扑是Java。
浏览 1提问于2019-05-31得票数 1
2回答
我正在尝试使用Eclipse在远程主机上提交Storm拓扑。StormSubmitter.submitTopology("classMain", conf, topology);Exception in thread "main" java.lang.RuntimeException: org.apache.thrift7.TApplicationException: Binary field exceeded
浏览 7提问于2015-10-16得票数 2
回答已采纳
我试图使用Windows上的storm命令将风暴拓扑部署到远程计算机上下面是我的storm.yaml文件中的内容：EDIT2System.setProperty("storm.jar", &
浏览 5提问于2015-10-06得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
