http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/jira-Commented-FLINK-885-Task-cancellation-fails-in-TempBarrier-close-tp79.html
> Task cancellation fails in TempBarrier.close()
> ----------------------------------------------
>
> Key: FLINK-885
> URL:
https://issues.apache.org/jira/browse/FLINK-885> Project: Flink
> Issue Type: Bug
> Reporter: Robert Metzger
> Labels: github-import
> Fix For: pre-apache
>
>
> Another issue in line with
https://github.com/stratosphere/stratosphere/issues/154 and
https://github.com/stratosphere/stratosphere/issues/281:> I got this issue while testing the testjob on the cluster with the current 0.5-rc3.
> ```
> 42 ERROR eu.stratosphere.pact.runtime.task.RegularPactTask - Error closing temp barrier for input 1
> java.lang.IndexOutOfBoundsException: Index: 1, Size: 0
> at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> at java.util.ArrayList.remove(ArrayList.java:474)
> at eu.stratosphere.pact.runtime.io.SpillingBuffer.moveAll(SpillingBuffer.java:188)
> at eu.stratosphere.pact.runtime.io.SpillingBuffer.close(SpillingBuffer.java:150)
> at eu.stratosphere.pact.runtime.task.TempBarrier.close(TempBarrier.java:121)
> at eu.stratosphere.pact.runtime.task.RegularPactTask.closeLocalStrategiesAndCaches(RegularPactTask.java:615)
> at eu.stratosphere.pact.runtime.task.RegularPactTask.cancel(RegularPactTask.java:404)
> at eu.stratosphere.nephele.taskmanager.runtime.RuntimeTask.cancelOrKillExecution(RuntimeTask.java:213)
> at eu.stratosphere.nephele.taskmanager.runtime.RuntimeTask.cancelExecution(RuntimeTask.java:174)
> at eu.stratosphere.nephele.taskmanager.TaskManager$2.run(TaskManager.java:592)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> 10:43:38,741 INFO eu.stratosphere.nephele.execution.ExecutionStateTransition - TM: ExecutionState set from RUNNING to CANCELING for task Join(T4 Join: All order keys) (136/208)
> 10:43:38,741 INFO eu.stratosphere.nephele.execution.ExecutionStateTransition - TM: ExecutionState set from CANCELING to CANCELED for task Join(T4 Join: All order keys) (133/208)
> 10:43:38,738 INFO eu.stratosphere.nephele.execution.ExecutionStateTransition - TM: ExecutionState set from CANCELING to CANCELED for task Join(T4 Join: All order keys) (131/208)
> 10:43:38,738 ERROR eu.stratosphere.pact.runtime.task.RegularPactTask - Error closing temp barrier for input 1
> java.lang.IndexOutOfBoundsException: Index: 1, Size: 0
> at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> at java.util.ArrayList.remove(ArrayList.java:474)
> at eu.stratosphere.pact.runtime.io.SpillingBuffer.moveAll(SpillingBuffer.java:188)
> at eu.stratosphere.pact.runtime.io.SpillingBuffer.close(SpillingBuffer.java:150)
> at eu.stratosphere.pact.runtime.task.TempBarrier.close(TempBarrier.java:121)
> at eu.stratosphere.pact.runtime.task.RegularPactTask.closeLocalStrategiesAndCaches(RegularPactTask.java:615)
> at eu.stratosphere.pact.runtime.task.RegularPactTask.cancel(RegularPactTask.java:404)
> at eu.stratosphere.nephele.taskmanager.runtime.RuntimeTask.cancelOrKillExecution(RuntimeTask.java:213)
> at eu.stratosphere.nephele.taskmanager.runtime.RuntimeTask.cancelExecution(RuntimeTask.java:174)
> at eu.stratosphere.nephele.taskmanager.TaskManager$2.run(TaskManager.java:592)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> 10:43:38,756 INFO eu.stratosphere.nephele.execution.ExecutionStateTransition - TM: ExecutionState set from CANCELING to CANCELED for task Join(T4 Join: All order keys) (136/208)
> ```
> ---------------- Imported from GitHub ----------------
> Url:
https://github.com/stratosphere/stratosphere/issues/885> Created by: [rmetzger|
https://github.com/rmetzger]
> Labels: bug, runtime,
> Created at: Thu May 29 10:49:52 CEST 2014
> State: open