出于测试/调试目的,是否有一种简单的方法可以手动终止风暴群集中的任务?最好的方法是从风暴ui启用它.即使风暴应该重新分配失败的任务,最好在它发生时测试我们的代码. 当然我可以在某些条件下在代码中添加’throw Runt…
标签:apache-storm
apache-storm – 经过一段时间后你会如何发布风暴数据?
例如,假设您使用storm来聚合Web访问的开始和结束日期.会话从用户的第一次访问开始,并在该同一用户不活动30分钟后结束.这些数据在收集时实时流入风暴.在30分钟不活动后,您如何告诉风暴发出数据? 最佳答案 我不确定但…
apache-storm – 线程“main”中的异常java.lang.IllegalAccessError:在storm拓扑中
当我运行我的风暴拓扑来读取Kafka主题并将数据写入Hive表时,我收到了IllegalAccesserror:错误详情如下: Exception in thread "main" java.lang.IllegalAc…
apache-storm – 风暴监督员,工人分配记忆
我有3个节点的风暴集群:主管-2,Nimbus-1. 3个节点有30 Gb的Ram和4个cpu核心.在我配置的配置中: supervisor.slots.ports : 8 (6700-6708) supervisor.…