flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1164) Uninformative error message when having an identity iteration with the Scala API
Date Sat, 18 Oct 2014 17:43:33 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14176062#comment-14176062
] 

ASF GitHub Bot commented on FLINK-1164:
---------------------------------------

Github user rmetzger commented on the pull request:

    https://github.com/apache/incubator-flink/pull/160#issuecomment-59623095
  
    Okay, I've tested the plan viz, all good. I'm going to merge this and include it into
the 0.7 release.


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

Mime
View raw message