tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-659. Fix init thread pool in LogicalIOProcessorRuntimeTask for tasks with no inputs and outputs. (hitesh)
Date Tue, 03 Dec 2013 00:28:14 GMT
Updated Branches:
  refs/heads/master e1f69184e -> 74207c4c7


TEZ-659. Fix init thread pool in LogicalIOProcessorRuntimeTask for tasks with no inputs and
outputs. (hitesh)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/74207c4c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/74207c4c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/74207c4c

Branch: refs/heads/master
Commit: 74207c4c7bb0f152762a8d2ffa417325c547bf3f
Parents: e1f6918
Author: Hitesh Shah <hitesh@apache.org>
Authored: Mon Dec 2 16:27:54 2013 -0800
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Mon Dec 2 16:27:54 2013 -0800

----------------------------------------------------------------------
 .../java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/74207c4c/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java
----------------------------------------------------------------------
diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java
b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java
index 0cfad93..979cda1 100644
--- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java
+++ b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java
@@ -127,7 +127,7 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask {
     this.eventsToBeProcessed = new LinkedBlockingQueue<TezEvent>();
     this.state = State.NEW;
     this.appAttemptNumber = appAttemptNumber;
-    int numInitializers = numInputs + numOutputs;
+    int numInitializers = numInputs + numOutputs + 1;
     this.initializerExecutor = Executors.newFixedThreadPool(
         numInitializers,
         new ThreadFactoryBuilder().setDaemon(true)


Mime
View raw message