I assume you are running storm in cluster mode on a remote machine. In this case, storm suggests you to use the storm jar command. It is true, that this by default accepts just a few arguments since it is internally using a python script that is calling java. But it seems to be possible to start storm with a java command as well and pass command line commands to that - see this link .
2条答案
按热度按时间pkwftd7m1#
I assume you are running storm in cluster mode on a remote machine. In this case, storm suggests you to use the
storm jar
command. It is true, that this by default accepts just a few arguments since it is internally using a python script that is calling java.But it seems to be possible to start storm with a java command as well and pass command line commands to that - see this link .
u3r8eeie2#
Another method to pass some variables to topology is the environment variable substitution in a flux file and run
when run in bash looks like:
Flag
-e
tells storm to substitute environment variables in the flux file