[
https://issues.apache.org/jira/browse/FLINK-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1164.
-----------------------------------
Resolution: Fixed
Fix Version/s: 0.7-incubating
Assignee: Stephan Ewen
Resolved in
http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/867e3a57
> Uninformative error message when having an identity iteration with the Scala
> API
> --------------------------------------------------------------------------------
>
> Key: FLINK-1164
> URL: https://issues.apache.org/jira/browse/FLINK-1164
> Project: Flink
> Issue Type: Bug
> Reporter: Till Rohrmann
> Assignee: Stephan Ewen
> Fix For: 0.7-incubating
>
>
> If one implements an identity mapper with the Scala API, then one gets a
> strange error message which might be very confusing for the user:
> Exception in thread "main"
> org.apache.flink.runtime.client.JobExecutionException: java.lang.Exception:
> Failed to deploy the task PartialSolution (BulkIteration (Bulk Iteration))
> (1/8) - execution #0 to slot SubSlot 1 (0bbe935796159bfe18abca6f1b32769a (0)
> - ALLOCATED/ALIVE): java.lang.Exception: The number of writers created in
> 'registerInputOutput()' is different than the number of connected outgoing
> edges in the job graph.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
