Repository: storm Updated Branches: refs/heads/master a4f9f8bc5 -> c55a028a7
Storm SQL - Storm.py 'storm sql' startup script is not working Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e9f7bf03 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e9f7bf03 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e9f7bf03 Branch: refs/heads/master Commit: e9f7bf03e3d40b199c6c1964b2be65fef0d4b213 Parents: aff4704 Author: Hugo Louro <[email protected]> Authored: Fri Jan 8 19:54:26 2016 -0800 Committer: Hugo Louro <[email protected]> Committed: Sat Jan 9 09:42:11 2016 -0800 ---------------------------------------------------------------------- bin/storm.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/e9f7bf03/bin/storm.py ---------------------------------------------------------------------- diff --git a/bin/storm.py b/bin/storm.py index 7414fdc..401d83f 100755 --- a/bin/storm.py +++ b/bin/storm.py @@ -17,11 +17,13 @@ # limitations under the License. import os -import sys import random -import subprocess as sub import re import shlex +import subprocess as sub + +import sys + try: # python 3 from urllib.parse import quote_plus @@ -229,7 +231,7 @@ def jar(jarfile, klass, *args): daemon=False, jvmopts=JAR_JVM_OPTS + ["-Dstorm.jar=" + jarfile]) -def sql(sql_file, topo_nam): +def sql(sql_file, topology_name): """Syntax: [storm sql sql-file topology] Compiles the SQL statements into a Trident topology and submits it to Storm. @@ -238,7 +240,7 @@ def sql(sql_file, topo_nam): "org.apache.storm.sql.StormSqlRunner", jvmtype="-client", extrajars=[USER_CONF_DIR, STORM_BIN_DIR], - args=[sql_file, topo_name], + args=[sql_file, topology_name], daemon=False) def kill(*args):
