flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-885) Task cancellation fails in TempBarrier.close()
Date Tue, 10 Jun 2014 16:33:02 GMT

     [ https://issues.apache.org/jira/browse/FLINK-885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Robert Metzger updated FLINK-885:
---------------------------------

    Reporter: Robert Metzger  (was: GitHub Import)

> 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)

Mime
View raw message