From 7a4c9400d5f00e39b06e09cb5a879096ca94d7fe Mon Sep 17 00:00:00 2001 From: Mike Thomsen Date: Sun, 14 Dec 2014 07:54:59 -0500 Subject: [PATCH 1/4] Added support for serialization to SequenceFileBolt Added support for org.apache.hadoop.io.serializer.Serialization to the SequenceFileBolt. The new SerializableSequenceFormat interface allows serialization systems like Avro to be plugged into the SequenceFileBolt. --- .../org/apache/storm/hdfs/bolt/format/SequenceFormat.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SequenceFormat.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SequenceFormat.java index e961730ff8a..cdadcc1f241 100644 --- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SequenceFormat.java +++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SequenceFormat.java @@ -18,7 +18,6 @@ package org.apache.storm.hdfs.bolt.format; import backtype.storm.tuple.Tuple; -import org.apache.hadoop.io.Writable; import java.io.Serializable; @@ -46,12 +45,12 @@ public interface SequenceFormat extends Serializable { * @param tuple * @return */ - Writable key(Tuple tuple); + Object key(Tuple tuple); /** * Given a tuple, return the value that should be written to the sequence file. * @param tuple * @return */ - Writable value(Tuple tuple); + Object value(Tuple tuple); } From b2f8eb651d3e8dbd7939aae126d803da6b948663 Mon Sep 17 00:00:00 2001 From: fmazoyer Date: Fri, 19 Dec 2014 17:12:57 +0100 Subject: [PATCH 2/4] STORM-248 STORM-322 proposal for fix --- bin/storm | 17 +++++++--- bin/storm-config.cmd | 32 +++++++++++++++++-- bin/storm.cmd | 12 +++---- .../clj/backtype/storm/daemon/supervisor.clj | 5 ++- 4 files changed, 52 insertions(+), 14 deletions(-) diff --git a/bin/storm b/bin/storm index 90f7634f355..fd4e5ca86a0 100755 --- a/bin/storm +++ b/bin/storm @@ -307,6 +307,13 @@ def repl(): cppaths = [CLUSTER_CONF_DIR] exec_storm_class("clojure.main", jvmtype="-client", extrajars=cppaths) +def get_logback_conf_dir(): + cppaths = [CLUSTER_CONF_DIR] + storm_logback_conf_dir = confvalue("storm.logback.conf.dir", cppaths) + if(storm_logback_conf_dir == None or storm_logback_conf_dir == "nil"): + storm_logback_conf_dir = STORM_DIR + "/logback" + return storm_logback_conf_dir + def nimbus(klass="backtype.storm.daemon.nimbus"): """Syntax: [storm nimbus] @@ -319,7 +326,7 @@ def nimbus(klass="backtype.storm.daemon.nimbus"): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("nimbus.childopts", cppaths)) + [ "-Dlogfile.name=nimbus.log", - "-Dlogback.configurationFile=" + STORM_DIR + "/logback/cluster.xml", + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml", ] exec_storm_class( klass, @@ -339,7 +346,7 @@ def supervisor(klass="backtype.storm.daemon.supervisor"): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("supervisor.childopts", cppaths)) + [ "-Dlogfile.name=supervisor.log", - "-Dlogback.configurationFile=" + STORM_DIR + "/logback/cluster.xml", + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml", ] exec_storm_class( klass, @@ -360,7 +367,7 @@ def ui(): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("ui.childopts", cppaths)) + [ "-Dlogfile.name=ui.log", - "-Dlogback.configurationFile=" + STORM_DIR + "/logback/cluster.xml", + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml" ] exec_storm_class( "backtype.storm.ui.core", @@ -381,7 +388,7 @@ def logviewer(): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("logviewer.childopts", cppaths)) + [ "-Dlogfile.name=logviewer.log", - "-Dlogback.configurationFile=" + STORM_DIR + "/logback/cluster.xml", + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml" ] exec_storm_class( "backtype.storm.daemon.logviewer", @@ -401,7 +408,7 @@ def drpc(): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("drpc.childopts", cppaths)) + [ "-Dlogfile.name=drpc.log", - "-Dlogback.configurationFile=" + STORM_DIR + "/logback/cluster.xml" + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml" ] exec_storm_class( "backtype.storm.daemon.drpc", diff --git a/bin/storm-config.cmd b/bin/storm-config.cmd index 9a11c34b798..5203241ea5a 100644 --- a/bin/storm-config.cmd +++ b/bin/storm-config.cmd @@ -49,7 +49,7 @@ if not defined JAVA_HOME ( set JAVA_HOME=c:\apps\java\openjdk7 ) -if not exist %JAVA_HOME%\bin\java.exe ( +if not exist "%JAVA_HOME%\bin\java.exe" ( echo Error: JAVA_HOME is incorrectly set. goto :eof ) @@ -82,10 +82,38 @@ if not defined STORM_LOG_DIR ( set STORM_LOG_DIR=%STORM_HOME%\logs ) +@rem +@rem retrieve storm.logback.conf.dir from conf file +@rem + +"%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value storm.logback.conf.dir > temp.txt + +FOR /F "delims=" %%i in (temp.txt) do ( + FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( + if %%a == VALUE: ( + set STORM_LOGBACK_CONFIGURATION_DIR=%%b + del /F temp.txt) + ) + ) +) + +@rem +@rem if STORM_LOGBACK_CONFIGURATION_DIR was defined, also set STORM_LOGBACK_CONFIGURATION_FILE +@rem + +if not %STORM_LOGBACK_CONFIGURATION_DIR% == nil ( + set STORM_LOGBACK_CONFIGURATION_FILE=%STORM_LOGBACK_CONFIGURATION_DIR%\cluster.xml +) + +@rem +@rem otherwise, fall back to default +@rem + if not defined STORM_LOGBACK_CONFIGURATION_FILE ( set STORM_LOGBACK_CONFIGURATION_FILE=%STORM_HOME%\logback\cluster.xml ) -%JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value java.library.path > temp.txt + +"%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value java.library.path > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( diff --git a/bin/storm.cmd b/bin/storm.cmd index 0cf6b526abd..d0d2c29488a 100644 --- a/bin/storm.cmd +++ b/bin/storm.cmd @@ -89,7 +89,7 @@ %JAVA% %JAVA_HEAP_MAX% %STORM_OPTS% %STORM_LOG_FILE% %CLASS% %storm-command-arguments% ) set path=%PATH%;%STORM_BIN_DIR%;%STORM_SBIN_DIR% - call start /b %JAVA% %JAVA_HEAP_MAX% %STORM_OPTS% %STORM_LOG_FILE% %CLASS% %storm-command-arguments% + call start /b "%storm-command%" "%JAVA%" %JAVA_HEAP_MAX% %STORM_OPTS% %STORM_LOG_FILE% %CLASS% %storm-command-arguments% goto :eof @@ -114,7 +114,7 @@ :drpc set CLASS=backtype.storm.daemon.drpc - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value drpc.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value drpc.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -140,7 +140,7 @@ :logviewer set CLASS=backtype.storm.daemon.logviewer - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value logviewer.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value logviewer.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -152,7 +152,7 @@ :nimbus set CLASS=backtype.storm.daemon.nimbus - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value nimbus.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value nimbus.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -184,7 +184,7 @@ :supervisor set CLASS=backtype.storm.daemon.supervisor - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value supervisor.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value supervisor.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -197,7 +197,7 @@ :ui set CLASS=backtype.storm.ui.core set CLASSPATH=%CLASSPATH%;%STORM_HOME% - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value ui.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value ui.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( diff --git a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj index d82fd12fb56..a371b9597c2 100644 --- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj +++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj @@ -608,6 +608,9 @@ storm-options (System/getProperty "storm.options") storm-conf-file (System/getProperty "storm.conf.file") storm-log-dir (or (System/getProperty "storm.log.dir") (str storm-home file-path-separator "logs")) + storm-conf (read-storm-config) + storm-log-conf-dir (storm-conf "storm.logback.conf.dir") + storm-logback-conf-dir (or storm-log-conf-dir (str storm-home file-path-separator "logback")) stormroot (supervisor-stormdist-root conf storm-id) jlp (jlp stormroot conf) stormjar (supervisor-stormjar-path stormroot) @@ -640,7 +643,7 @@ (str "-Dstorm.conf.file=" storm-conf-file) (str "-Dstorm.options=" storm-options) (str "-Dstorm.log.dir=" storm-log-dir) - (str "-Dlogback.configurationFile=" storm-home file-path-separator "logback" file-path-separator "worker.xml") + (str "-Dlogback.configurationFile=" storm-logback-conf-dir file-path-separator "worker.xml") (str "-Dstorm.id=" storm-id) (str "-Dworker.id=" worker-id) (str "-Dworker.port=" port) From ab76e67ccc67349a8483e8ee314621303d6a2fbd Mon Sep 17 00:00:00 2001 From: Sriharsha Chintalapani Date: Tue, 30 Dec 2014 09:50:21 -0800 Subject: [PATCH 3/4] added STORM-595 to changelog. --- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index fc5a65bf028..8ccaecedaf3 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,4 +1,5 @@ ## 0.10.0 + * STORM-595: storm-hdfs can only work with sequence files that use Writables. * STORM-487: Remove storm.cmd, no need to duplicate work python runs on windows too. * STORM-585: Performance issue in none grouping * STORM-525: Add time sorting function to the 2nd col of bolt exec table From 49688fd5856e81d947255aca9cca4252d8243945 Mon Sep 17 00:00:00 2001 From: fmazoyer Date: Fri, 19 Dec 2014 17:12:57 +0100 Subject: [PATCH 4/4] STORM-248 STORM-322 proposal for fix --- bin/storm | 17 +++++++--- bin/storm-config.cmd | 32 +++++++++++++++++-- bin/storm.cmd | 12 +++---- .../clj/backtype/storm/daemon/supervisor.clj | 5 ++- 4 files changed, 52 insertions(+), 14 deletions(-) diff --git a/bin/storm b/bin/storm index 83f5a9f9701..345bcbe5f24 100755 --- a/bin/storm +++ b/bin/storm @@ -312,6 +312,13 @@ def repl(): cppaths = [CLUSTER_CONF_DIR] exec_storm_class("clojure.main", jvmtype="-client", extrajars=cppaths) +def get_logback_conf_dir(): + cppaths = [CLUSTER_CONF_DIR] + storm_logback_conf_dir = confvalue("storm.logback.conf.dir", cppaths) + if(storm_logback_conf_dir == None or storm_logback_conf_dir == "nil"): + storm_logback_conf_dir = STORM_DIR + "/logback" + return storm_logback_conf_dir + def nimbus(klass="backtype.storm.daemon.nimbus"): """Syntax: [storm nimbus] @@ -324,7 +331,7 @@ def nimbus(klass="backtype.storm.daemon.nimbus"): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("nimbus.childopts", cppaths)) + [ "-Dlogfile.name=nimbus.log", - "-Dlogback.configurationFile=" + STORM_LOGBACK_FILE_PATH, + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml", ] exec_storm_class( klass, @@ -344,7 +351,7 @@ def supervisor(klass="backtype.storm.daemon.supervisor"): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("supervisor.childopts", cppaths)) + [ "-Dlogfile.name=supervisor.log", - "-Dlogback.configurationFile=" + STORM_LOGBACK_FILE_PATH, + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml", ] exec_storm_class( klass, @@ -365,7 +372,7 @@ def ui(): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("ui.childopts", cppaths)) + [ "-Dlogfile.name=ui.log", - "-Dlogback.configurationFile=" + STORM_LOGBACK_FILE_PATH, + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml" ] exec_storm_class( "backtype.storm.ui.core", @@ -386,7 +393,7 @@ def logviewer(): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("logviewer.childopts", cppaths)) + [ "-Dlogfile.name=logviewer.log", - "-Dlogback.configurationFile=" + STORM_LOGBACK_FILE_PATH, + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml" ] exec_storm_class( "backtype.storm.daemon.logviewer", @@ -406,7 +413,7 @@ def drpc(): cppaths = [CLUSTER_CONF_DIR] jvmopts = parse_args(confvalue("drpc.childopts", cppaths)) + [ "-Dlogfile.name=drpc.log", - "-Dlogback.configurationFile=" + STORM_LOGBACK_FILE_PATH, + "-Dlogback.configurationFile=" + get_logback_conf_dir() + "/cluster.xml" ] exec_storm_class( "backtype.storm.daemon.drpc", diff --git a/bin/storm-config.cmd b/bin/storm-config.cmd index 9a11c34b798..5203241ea5a 100644 --- a/bin/storm-config.cmd +++ b/bin/storm-config.cmd @@ -49,7 +49,7 @@ if not defined JAVA_HOME ( set JAVA_HOME=c:\apps\java\openjdk7 ) -if not exist %JAVA_HOME%\bin\java.exe ( +if not exist "%JAVA_HOME%\bin\java.exe" ( echo Error: JAVA_HOME is incorrectly set. goto :eof ) @@ -82,10 +82,38 @@ if not defined STORM_LOG_DIR ( set STORM_LOG_DIR=%STORM_HOME%\logs ) +@rem +@rem retrieve storm.logback.conf.dir from conf file +@rem + +"%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value storm.logback.conf.dir > temp.txt + +FOR /F "delims=" %%i in (temp.txt) do ( + FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( + if %%a == VALUE: ( + set STORM_LOGBACK_CONFIGURATION_DIR=%%b + del /F temp.txt) + ) + ) +) + +@rem +@rem if STORM_LOGBACK_CONFIGURATION_DIR was defined, also set STORM_LOGBACK_CONFIGURATION_FILE +@rem + +if not %STORM_LOGBACK_CONFIGURATION_DIR% == nil ( + set STORM_LOGBACK_CONFIGURATION_FILE=%STORM_LOGBACK_CONFIGURATION_DIR%\cluster.xml +) + +@rem +@rem otherwise, fall back to default +@rem + if not defined STORM_LOGBACK_CONFIGURATION_FILE ( set STORM_LOGBACK_CONFIGURATION_FILE=%STORM_HOME%\logback\cluster.xml ) -%JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value java.library.path > temp.txt + +"%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value java.library.path > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( diff --git a/bin/storm.cmd b/bin/storm.cmd index 0cf6b526abd..d0d2c29488a 100644 --- a/bin/storm.cmd +++ b/bin/storm.cmd @@ -89,7 +89,7 @@ %JAVA% %JAVA_HEAP_MAX% %STORM_OPTS% %STORM_LOG_FILE% %CLASS% %storm-command-arguments% ) set path=%PATH%;%STORM_BIN_DIR%;%STORM_SBIN_DIR% - call start /b %JAVA% %JAVA_HEAP_MAX% %STORM_OPTS% %STORM_LOG_FILE% %CLASS% %storm-command-arguments% + call start /b "%storm-command%" "%JAVA%" %JAVA_HEAP_MAX% %STORM_OPTS% %STORM_LOG_FILE% %CLASS% %storm-command-arguments% goto :eof @@ -114,7 +114,7 @@ :drpc set CLASS=backtype.storm.daemon.drpc - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value drpc.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value drpc.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -140,7 +140,7 @@ :logviewer set CLASS=backtype.storm.daemon.logviewer - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value logviewer.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value logviewer.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -152,7 +152,7 @@ :nimbus set CLASS=backtype.storm.daemon.nimbus - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value nimbus.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value nimbus.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -184,7 +184,7 @@ :supervisor set CLASS=backtype.storm.daemon.supervisor - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value supervisor.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value supervisor.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( @@ -197,7 +197,7 @@ :ui set CLASS=backtype.storm.ui.core set CLASSPATH=%CLASSPATH%;%STORM_HOME% - %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value ui.childopts > temp.txt + "%JAVA%" -client -Dstorm.options= -Dstorm.conf.file= -cp "%CLASSPATH%" backtype.storm.command.config_value ui.childopts > temp.txt FOR /F "delims=" %%i in (temp.txt) do ( FOR /F "tokens=1,* delims= " %%a in ("%%i") do ( if %%a == VALUE: ( diff --git a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj index 8187843189c..81ecf0f4c28 100644 --- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj +++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj @@ -614,6 +614,9 @@ storm-options (System/getProperty "storm.options") storm-conf-file (System/getProperty "storm.conf.file") storm-log-dir (or (System/getProperty "storm.log.dir") (str storm-home file-path-separator "logs")) + storm-conf (read-storm-config) + storm-log-conf-dir (storm-conf "storm.logback.conf.dir") + storm-logback-conf-dir (or storm-log-conf-dir (str storm-home file-path-separator "logback")) stormroot (supervisor-stormdist-root conf storm-id) jlp (jlp stormroot conf) stormjar (supervisor-stormjar-path stormroot) @@ -646,7 +649,7 @@ (str "-Dstorm.conf.file=" storm-conf-file) (str "-Dstorm.options=" storm-options) (str "-Dstorm.log.dir=" storm-log-dir) - (str "-Dlogback.configurationFile=" storm-home file-path-separator "logback" file-path-separator "worker.xml") + (str "-Dlogback.configurationFile=" storm-logback-conf-dir file-path-separator "worker.xml") (str "-Dstorm.id=" storm-id) (str "-Dworker.id=" worker-id) (str "-Dworker.port=" port)