You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2017/04/05 15:42:40 UTC
apex-core git commit: APEXCORE-690 apply HEARTBEAT_MONITORING setting
in embedded app launcher.
Repository: apex-core
Updated Branches:
refs/heads/master 9054fd2b9 -> 869e166e1
APEXCORE-690 apply HEARTBEAT_MONITORING setting in embedded app launcher.
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/869e166e
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/869e166e
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/869e166e
Branch: refs/heads/master
Commit: 869e166e1c733fc8bfe1acf189f5d9ff7f654fdc
Parents: 9054fd2
Author: Thomas Weise <th...@apache.org>
Authored: Wed Apr 5 08:17:26 2017 -0700
Committer: Thomas Weise <th...@apache.org>
Committed: Wed Apr 5 08:17:26 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/869e166e/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java b/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java
index 5930e78..958907d 100644
--- a/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java
+++ b/engine/src/main/java/org/apache/apex/engine/EmbeddedAppLauncherImpl.java
@@ -79,9 +79,7 @@ public class EmbeddedAppLauncherImpl extends LocalMode<EmbeddedAppLauncherImpl.E
throw new LauncherException(e);
}
}
- if (StramUtils.getValueWithDefault(launchParameters, HEARTBEAT_MONITORING)) {
- lc.setHeartbeatMonitoringEnabled(true);
- }
+ lc.setHeartbeatMonitoringEnabled(StramUtils.getValueWithDefault(launchParameters, HEARTBEAT_MONITORING));
if (StramUtils.getValueWithDefault(launchParameters, RUN_ASYNC)) {
lc.runAsync();
launched = true;