笔者在安装storm的过程中,出现了一些错误
1、安装zeroMQ时
./configure的时候出现
系统缺少相应的依赖包,可以用这个来安装,里面包括linux的一些util包,可以在这个中下载
2、storm执行文件时用python写的,启动./storm nimbus的时候,执行到confvalue函数中 p = sub.Popen(command, stdout=sub.PIPE)出现找不到文件的异常。
函数如下:
def confvalue(name, extrapaths):
print name+":"+ get_classpath(extrapaths)
command = [
"java", "-client", get_config_opts(), "-cp", get_classpath(extrapaths), "backtype.storm.command.config_value", name
]
p = sub.Popen(command, stdout=sub.PIPE)
output, errors = p.communicate()
lines = output.split("\n")
for line in lines:
tokens = line.split(" ")
if tokens[0] == "VALUE:":
return " ".join(tokens[1:])
return ""
可见在sub.Popen(command, stdout=sub.PIPE)中,执行了java 命令,需要把java命令设置到系统的环境变量中才可以。