You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 17:50:05 UTC
[jira] [Closed] (FLINK-885) Task cancellation fails in
TempBarrier.close()
[ https://issues.apache.org/jira/browse/FLINK-885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen closed FLINK-885.
------------------------------
> 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
>
> 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.3.4#6332)