使用storm\u jar\u jvm\u opts env属性时,属性传递不正确。
我在风暴启动计划中遇到了问题(https://github.com/nathanmarz/storm-starter).
首先在storm.starter.wordcounttopology中main方法的开头插入以下行:
String property = System.getProperty("properties.folder");
System.out.println("PROPERTIES.FOLDER: " + property);
然后设置storm\u jar\u jvm\u opts:
export STORM_JAR_JVM_OPTS=-Dproperties.folder=/tmp/properties
现在用mvn包构建jar并将jar提交给storm:
./storm jar storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology
这将打印
PROPERTIES.FOLDER: /tmp/properties -Dstorm.jar=/vagrant/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar
我只需要/tmp/properties,而且-d显示出来有点奇怪。当获取属性storm.jar时,它返回null,这也是我没想到的。
我是否正确使用了storm\u jar\u jvm\u opts?
谢谢你的帮助!
1条答案
按热度按时间sdnqo3pr1#
这个问题在版本0.9.2——风暴的孵化中得到了解决(我使用的是0.9.0.1)
谢谢你的评论!