You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/18 19:49:33 UTC

[jira] [Resolved] (FLINK-1164) Uninformative error message when having an identity iteration with the Scala API

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