Apache Storm集群模式下FileNotFoundException异常



我尝试在集群(分布式)模式下部署风暴拓扑。不幸的是,我得到了一个FileNotFoundException,我找不到我犯的任何错误。如果你能帮我找出问题所在,我将不胜感激。

我使用的是Storm 1.0.1版本。Zookeeper list运行在另一个虚拟机上。

出现以下堆栈跟踪:

[{:type java.lang.RuntimeException:message java.io.IOException: No。这样的文件或目录[org.apache.storm.blobstore。LocalFsBlobStore createBlobLocalFsBlobStore.java 117]}{:类型java.io.IOException:消息没有这样的文件或目录:at [java.io.UnixFileSystem]createfileexclusive unixfilessystem .java -2]}]:trace[[. io .UnixFileSystem.java -2(io。File createNewFile File.java 1012]
[org.apache.storm.blobstore。LocalFsBlobStoreFile getOutputStreamLocalFsBlobStoreFile.java 109]
[org.apache.storm.blobstore.BlobStore BlobStoreFileOutputStream美元[org.apache.storm.blobstore.LocalFsBlobStore .javacreateBlob LocalFsBlobStore.java 111]
[org.apache.storm.blobstore。BlobStore.java 217]

我解决了我的情况,希望这也是一个解决你的问题。

storm安装想要写入的文件位于本地blob存储中,位于storm.local.dir + /blobs(默认情况下,在安装storm的目录中是storm-local/blobs)。您应该检查权限是否与您用来运行Storm的用户匹配。

在我的例子中,我的Systemd服务文件中的用户和组信息出现在exec之后,因此它不起作用。如果你也使用Systemd来启动nimbus,使用这个模板:

[Unit]
Description=start and stop storm nimbus
After=network.target
[Service]
User=storm
Group=storm
WorkingDirectory=/home/storm/apache-storm-1.0.2
ExecStart=/home/storm/apache-storm-1.0.2/bin/storm nimbus
Restart=on-failure

最新更新