Repository: beam Updated Branches: refs/heads/jstorm-runner e00e0e841 -> 914889925
jstorm-runner: Fix the bug that max waiting time is missing on local mode Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/557d7036 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/557d7036 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/557d7036 Branch: refs/heads/jstorm-runner Commit: 557d7036efe3bcb83ea99ca14ad052052bab5add Parents: e00e0e8 Author: basti.lj <basti...@alibaba-inc.com> Authored: Wed Aug 30 10:45:17 2017 +0800 Committer: Pei He <p...@apache.org> Committed: Wed Aug 30 14:55:15 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/jstorm/JStormRunnerResult.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/557d7036/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/JStormRunnerResult.java ---------------------------------------------------------------------- diff --git a/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/JStormRunnerResult.java b/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/JStormRunnerResult.java index 4b1850e..b6b5281 100644 --- a/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/JStormRunnerResult.java +++ b/runners/jstorm/src/main/java/org/apache/beam/runners/jstorm/JStormRunnerResult.java @@ -64,8 +64,8 @@ public abstract class JStormRunnerResult implements PipelineResult { private static class LocalJStormPipelineResult extends JStormRunnerResult { - private LocalCluster localCluster; - private long localModeExecuteTimeSecs; + private final LocalCluster localCluster; + private final long localModeExecuteTimeSecs; LocalJStormPipelineResult( String topologyName, @@ -74,6 +74,7 @@ public abstract class JStormRunnerResult implements PipelineResult { long localModeExecuteTimeSecs) { super(topologyName, config); this.localCluster = checkNotNull(localCluster, "localCluster"); + this.localModeExecuteTimeSecs = localModeExecuteTimeSecs; } @Override
