Repository: incubator-gearpump Updated Branches: refs/heads/master cb6aced50 -> 2d2f27953
[GEARPUMP-362] Fix bin/gear info shows nothing when there are apps ru⦠â¦nning Author: huafengw <[email protected]> Closes #236 from huafengw/info. Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/2d2f2795 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/2d2f2795 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/2d2f2795 Branch: refs/heads/master Commit: 2d2f279533a221c7b9317440a13cd2570267b85e Parents: cb6aced Author: huafengw <[email protected]> Authored: Sat Oct 28 13:20:41 2017 +0800 Committer: manuzhang <[email protected]> Committed: Sat Oct 28 13:21:00 2017 +0800 ---------------------------------------------------------------------- .../scala/org/apache/gearpump/cluster/main/AppSubmitter.scala | 2 -- core/src/main/scala/org/apache/gearpump/cluster/main/Gear.scala | 3 +++ 2 files changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/2d2f2795/core/src/main/scala/org/apache/gearpump/cluster/main/AppSubmitter.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/gearpump/cluster/main/AppSubmitter.scala b/core/src/main/scala/org/apache/gearpump/cluster/main/AppSubmitter.scala index c5ddcb0..79f31eb 100644 --- a/core/src/main/scala/org/apache/gearpump/cluster/main/AppSubmitter.scala +++ b/core/src/main/scala/org/apache/gearpump/cluster/main/AppSubmitter.scala @@ -21,7 +21,6 @@ import java.io.File import java.net.{URL, URLClassLoader} import java.util.jar.JarFile -import org.apache.gearpump.cluster.client.{RemoteRuntimeEnvironment, RuntimeEnvironment} import org.apache.gearpump.util.{AkkaApp, Constants, LogUtil, Util} import scala.util.{Failure, Success, Try} @@ -85,7 +84,6 @@ object AppSubmitter extends AkkaApp with ArgumentsParser { Thread.currentThread().setContextClassLoader(classLoader) val clazz = classLoader.loadClass(main) val mainMethod = clazz.getMethod("main", classOf[Array[String]]) - RuntimeEnvironment.setRuntimeEnv(new RemoteRuntimeEnvironment) mainMethod.invoke(null, arguments) } } http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/2d2f2795/core/src/main/scala/org/apache/gearpump/cluster/main/Gear.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/gearpump/cluster/main/Gear.scala b/core/src/main/scala/org/apache/gearpump/cluster/main/Gear.scala index b1737f7..7301819 100644 --- a/core/src/main/scala/org/apache/gearpump/cluster/main/Gear.scala +++ b/core/src/main/scala/org/apache/gearpump/cluster/main/Gear.scala @@ -18,6 +18,7 @@ package org.apache.gearpump.cluster.main import org.apache.gearpump.cluster.ClusterConfig +import org.apache.gearpump.cluster.client.{RemoteRuntimeEnvironment, RuntimeEnvironment} import org.apache.gearpump.util.LogUtil.ProcessType import org.apache.gearpump.util.{Constants, LogUtil} @@ -53,6 +54,8 @@ object Gear { System.setProperty(Constants.GEARPUMP_CUSTOM_CONFIG_FILE, configFile) } + RuntimeEnvironment.setRuntimeEnv(new RemoteRuntimeEnvironment) + if (args.length == 0) { printUsage() } else {
