[jira] [Assigned] (FLINK-123) Strange (and faulty) Iterations Behaviour

["Matthias Pohl (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias Pohl reassigned FLINK-123:
-----------------------------------

    Assignee: Matthias Pohl

> Strange (and faulty) Iterations Behaviour
> -----------------------------------------
>
>                 Key: FLINK-123
>                 URL: https://issues.apache.org/jira/browse/FLINK-123
>             Project: Flink
>          Issue Type: Bug
>            Reporter: GitHub Import
>            Assignee: Matthias Pohl
>            Priority: Major
>              Labels: github-import
>             Fix For: pre-apache
>
>
> In KMeansIterative, when you add an identity mapper after the reduceClusterCenter reducer you get:
> java.lang.RuntimeException: : BUG: The task must have at least one output
> 	at eu.stratosphere.pact.runtime.task.RegularPactTask.registerInputOutput(RegularPactTask.java:248)
> 	at eu.stratosphere.nephele.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:194)
> 	at eu.stratosphere.nephele.executiongraph.ExecutionGroupVertex.<init>(ExecutionGroupVertex.java:237)
> 	at eu.stratosphere.nephele.executiongraph.ExecutionGraph.createVertex(ExecutionGraph.java:497)
> 	at eu.stratosphere.nephele.executiongraph.ExecutionGraph.constructExecutionGraph(ExecutionGraph.java:275)
> 	at eu.stratosphere.nephele.executiongraph.ExecutionGraph.<init>(ExecutionGraph.java:176)
> 	at eu.stratosphere.nephele.jobmanager.JobManager.submitJob(JobManager.java:532)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:606)
> 	at eu.stratosphere.nephele.ipc.RPC$Server.call(RPC.java:417)
> 	at eu.stratosphere.nephele.ipc.Server$Handler.run(Server.java:946)
> I discovered this one from a plan in the scala frontend where I also have a final mapper that does some real work after a reducer in an iteration (BulkIteration).
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/123
> Created by: [aljoscha|https://github.com/aljoscha]
> Labels: bug, 
> Milestone: Release 0.4
> Assignee: [StephanEwen|https://github.com/StephanEwen]
> Created at: Thu Oct 03 09:16:36 CEST 2013
> State: closed



--
This message was sent by Atlassian Jira
(v8.20.1#820001)