[
https://issues.apache.org/jira/browse/FLINK-897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-897.
--------------------------------
Resolution: Fixed
Fixed in new scheduler, as of cdee87501762c092c216adf35fceeea339e0c4c4
> Bug in scheduler for job graph instance sharing
> -----------------------------------------------
>
> Key: FLINK-897
> URL: https://issues.apache.org/jira/browse/FLINK-897
> Project: Flink
> Issue Type: Bug
> Reporter: GitHub Import
> Labels: github-import
> Fix For: pre-apache
>
>
> I discovered the following problem while writing a low-level task: the
> scheduler could not bring up the instance for `forwarder3` (state
> `SCHEDULED`, but not `ASSIGNED`).
> ```
> producer => forwarder0 => forwarder1 => forwarder2 => forwarder3 => consumer
> ```
> ```java
> producer.setVertexToShareInstancesWith(forwarder0);
> forwarder0.setVertexToShareInstancesWith(forwarder1);
> forwarder1.setVertexToShareInstancesWith(forwarder2);
> forwarder2.setVertexToShareInstancesWith(forwarder3);
> forwarder3.setVertexToShareInstancesWith(consumer);
> ```
> Every task should share the vertex. The following equivalent sharing did work
> though:
> ```
> forwarder0 ================> producer
> forwarder1 ===// // // //
> forwarder2 =====// // //
> forwarder3 =======// //
> consumer =========//
> ```
> ```java
> forwarder0.setVertexToShareInstancesWith(producer);
> forwarder1.setVertexToShareInstancesWith(producer);
> forwarder2.setVertexToShareInstancesWith(producer);
> forwarder3.setVertexToShareInstancesWith(producer);
> consumer.setVertexToShareInstancesWith(producer);
> ```
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/897
> Created by: [uce|https://github.com/uce]
> Labels: bug, core,
> Created at: Mon Jun 02 14:57:03 CEST 2014
> State: open
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
