在这个问题上我需要你的一些帮助。我读到spout负责读取数据或准备在Bolt中处理数据。因此,我在spout中编写了一些代码来打开文件并逐行读取
class SimSpout(storm.Spout):
# Not much to do here for such a basic spout
def initialize(self, conf, context):
## Open the file with read only permit
self.f = open('data.txt', 'r')
## Rea
Supervisor.log中的错误消息:风暴监控器猫不能同时创建stormClusterState,它在zk.The nimbus进程的/zk.The/zk.The目录中是空的,但是监督者不能start.why?
org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:663)~storm-client-2.3.0.jar:2.3.0 at org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:667)~storm-client-2.3.0.jar
我已经在本地设置了一个Apache集群,并提交了一个在Storm UI中可见的拓扑。一旦一切都启动并运行,我将在ui.log文件中获得以下异常。这个错误在某种程度上与storm-kafka-monitor有关,这是一个bash脚本,我正在windows上运行这个脚本。
任何帮助都将不胜感激。(预先谢谢:)
2018-06-05 11:26:20.293 o.a.s.u.TopologySpoutLag qtp1185188034-26 [WARN] Exception thrown while getting lag for spout id: kafka-spout and spout cl
在ajax.py中,我有这样一个导入语句:
import components.db_init as db
在components/db_init.py中,我有这样的import语句:
# import locals from ORM (Storm)
from storm.locals import *
在components/storm/locals.py中,它具有以下内容:
from storm.properties import Bool, Int, Float, RawStr, Chars, Unicode, Pickle
from storm.properties import Li
我试图以守护进程的形式运行一个进程,并在pidfile中编写它的PID。但是当我运行它时,它会给我一个错误:
daemon: fatal: failed to tell if /home/ubuntu/storm/storm-0.8.2/bin/storm supervisor > /dev/null && echo $! > /var/run/supervisor-storm.pid is safe: No such file or directory
以下是代码:
PID_FILE=/var/run/supervisor-storm.pid
STORM_BIN=
我必须创建一个程序来读取Storm.dat文件(包含海洋风暴并生成简短的报告)。我已经制作了必要的文件,但是我在Makefile中遇到了一些问题。
下面是我的代码:
storm.h
#ifndef STORMS_H
#define STORMS_H
class Storm
{
private:
char where; // A, E, C
char name[11]; // recall '\0'
int seq; // sequence num 1...
int year;
int max_wind; // knots
int