You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2017/10/28 05:21:16 UTC
incubator-gearpump git commit: [GEARPUMP-362] Fix bin/gear info shows nothing when there are apps ru…
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 <fv...@gmail.com>
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 <fv...@gmail.com>
Authored: Sat Oct 28 13:20:41 2017 +0800
Committer: manuzhang <ow...@gmail.com>
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 {