Repository: incubator-beam Updated Branches: refs/heads/master 921d0b2e7 -> 064796dcc
Remove unused constant in ExecutorServiceParallelExecutor Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b562072b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b562072b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b562072b Branch: refs/heads/master Commit: b562072b868bff14d7c33a64d05056c604710884 Parents: 921d0b2 Author: Thomas Groh <[email protected]> Authored: Mon Aug 22 09:23:57 2016 -0700 Committer: Thomas Groh <[email protected]> Committed: Mon Aug 22 09:23:57 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/ExecutorServiceParallelExecutor.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b562072b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java index 8c6c6ed..35b6239 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java @@ -338,8 +338,6 @@ final class ExecutorServiceParallelExecutor implements PipelineExecutor { } private class MonitorRunnable implements Runnable { - // arbitrary termination condition to ensure progress in the presence of pushback - private final long maxTimeProcessingUpdatesNanos = TimeUnit.MILLISECONDS.toNanos(5L); private final String runnableName = String.format("%s$%s-monitor", evaluationContext.getPipelineOptions().getAppName(), ExecutorServiceParallelExecutor.class.getSimpleName());
