beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [1/3] incubator-beam git commit: Remove unused constant in ExecutorServiceParallelExecutor
Date Mon, 22 Aug 2016 19:09:22 GMT
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 <tgroh@google.com>
Authored: Mon Aug 22 09:23:57 2016 -0700
Committer: Thomas Groh <tgroh@google.com>
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());


Mime
View raw message