stand-alone nimbus
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/f83be158 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/f83be158 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/f83be158 Branch: refs/heads/master Commit: f83be158e922bec41d6d0431230e63a39e15546a Parents: 502dbae Author: manuzhang <[email protected]> Authored: Mon Feb 1 16:56:11 2016 +0800 Committer: manuzhang <[email protected]> Committed: Mon Feb 1 16:56:11 2016 +0800 ---------------------------------------------------------------------- .../io/gearpump/experiments/storm/main/GearpumpNimbus.scala | 4 +++- .../io/gearpump/experiments/storm/main/GearpumpStormClient.scala | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/f83be158/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpNimbus.scala ---------------------------------------------------------------------- diff --git a/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpNimbus.scala b/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpNimbus.scala index 4204580..83328b4 100644 --- a/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpNimbus.scala +++ b/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpNimbus.scala @@ -59,7 +59,9 @@ object GearpumpNimbus extends AkkaApp with ArgumentsParser { val system = ActorSystem("storm", akkaConf) val clientContext = new ClientContext(akkaConf, system, null) val stormConf = Utils.readStormConfig().asInstanceOf[JMap[AnyRef, AnyRef]] - val thriftConf: JMap[String, String] = Map(Config.NIMBUS_THRIFT_PORT -> s"$THRIFT_PORT").asJava + val thriftConf: JMap[String, String] = Map( + Config.NIMBUS_HOST -> akkaConf.getString(Constants.GEARPUMP_HOSTNAME), + Config.NIMBUS_THRIFT_PORT -> s"$THRIFT_PORT").asJava updateOutputStormConfig(thriftConf, output) stormConf.putAll(thriftConf) val thriftServer = createServer(clientContext, stormConf) http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/f83be158/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpStormClient.scala ---------------------------------------------------------------------- diff --git a/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpStormClient.scala b/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpStormClient.scala index 70efbf3..b813ae0 100644 --- a/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpStormClient.scala +++ b/experiments/storm/src/main/scala/io/gearpump/experiments/storm/main/GearpumpStormClient.scala @@ -63,7 +63,8 @@ object GearpumpStormClient extends AkkaApp with ArgumentsParser { private def getThriftOptions(stormConfig: String): String = { val config = Utils.findAndReadConfigFile(stormConfig, true) + val host = config.get(Config.NIMBUS_HOST) val thriftPort = config.get(Config.NIMBUS_THRIFT_PORT) - s"${Config.NIMBUS_HOST}=127.0.0.1,${Config.NIMBUS_THRIFT_PORT}=$thriftPort" + s"${Config.NIMBUS_HOST}=$host,${Config.NIMBUS_THRIFT_PORT}=$thriftPort" } }
