[jira] [Commented] (FLINK-885) Task cancellation fails in TempBarrier.close()

[Shang Yuanchun (Jira)]

    [ https://issues.apache.org/jira/browse/FLINK-885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14029131#comment-14029131 ]

Robert Waury commented on FLINK-885:
------------------------------------

Please open a new issue for the CompactingHashTable bug.

> 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

--
This message was sent by Atlassian JIRA
(v6.2#6252)