You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/05/21 17:27:33 UTC
[3/8] git commit: STORM-308 Add support for config_value to
{supervisor, nimbus, ui, drpc, logviewer} childopts
STORM-308 Add support for config_value to {supervisor,nimbus,ui,drpc,logviewer} childopts
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/85f3bddc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/85f3bddc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/85f3bddc
Branch: refs/heads/master
Commit: 85f3bddc24774c5f62af71069c522cb32b1bc58f
Parents: 442752b
Author: ChitturiPadma <pa...@gmail.com>
Authored: Tue May 6 16:44:18 2014 +0530
Committer: ChitturiPadma <pa...@gmail.com>
Committed: Tue May 6 16:44:18 2014 +0530
----------------------------------------------------------------------
bin/storm.cmd | 31 +++++++++++++++++++++++++++++++
1 file changed, 31 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/85f3bddc/bin/storm.cmd
----------------------------------------------------------------------
diff --git a/bin/storm.cmd b/bin/storm.cmd
index a12d359..3eca1bc 100644
--- a/bin/storm.cmd
+++ b/bin/storm.cmd
@@ -106,6 +106,12 @@
:drpc
set CLASS=backtype.storm.daemon.drpc
set STORM_OPTS=%STORM_SERVER_OPTS% %STORM_OPTS%
+ %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value drpc.childopts > temp.txt
+ FOR /F "tokens=1,* delims= " %%i in (temp.txt) do (
+ if %%i == VALUE: (
+ set JAVA_HEAP_MAX=%%j )
+ )
+ del /F temp.txt
goto :eof
:help
@@ -125,11 +131,23 @@
:logviewer
set CLASS=backtype.storm.daemon.logviewer
set STORM_OPTS=%STORM_SERVER_OPTS% %STORM_OPTS%
+ %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value logviewer.childopts > temp.txt
+ FOR /F "tokens=1,* delims= " %%i in (temp.txt) do (
+ if %%i == VALUE: (
+ set JAVA_HEAP_MAX=%%j )
+ )
+ del /F temp.txt
goto :eof
:nimbus
set CLASS=backtype.storm.daemon.nimbus
set STORM_OPTS=%STORM_SERVER_OPTS% %STORM_OPTS%
+ %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value nimbus.childopts > temp.txt
+ FOR /F "tokens=1,* delims= " %%i in (temp.txt) do (
+ if %%i == VALUE: (
+ set JAVA_HEAP_MAX=%%j )
+ )
+ del /F temp.txt
goto :eof
:rebalance
@@ -150,12 +168,25 @@
:supervisor
set CLASS=backtype.storm.daemon.supervisor
set STORM_OPTS=%STORM_SERVER_OPTS% %STORM_OPTS%
+ %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value supervisor.childopts > temp.txt
+ FOR /F "tokens=1,* delims= " %%i in (temp.txt) do (
+ if %%i == VALUE: (
+ set JAVA_HEAP_MAX=%%j )
+ )
+ del /F temp.txt
+
goto :eof
:ui
set CLASS=backtype.storm.ui.core
set CLASSPATH=%CLASSPATH%;%STORM_HOME%
set STORM_OPTS=%STORM_SERVER_OPTS% %STORM_OPTS%
+ %JAVA% -client -Dstorm.options= -Dstorm.conf.file= -cp %CLASSPATH% backtype.storm.command.config_value ui.childopts > temp.txt
+ FOR /F "tokens=1,* delims= " %%i in (temp.txt) do (
+ if %%i == VALUE: (
+ set JAVA_HEAP_MAX=%%j )
+ )
+ del /F temp.txt
goto :eof
:version