Till Rohrmann created FLINK-1164:
------------------------------------
Summary: 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
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)
