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-1143) Forced to use Solution Set
Date Mon, 13 Oct 2014 19:45:34 GMT

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

ASF GitHub Bot commented on FLINK-1143:

GitHub user StephanEwen opened a pull request:


    [FLINK-1143] Allow delta iterations that do not join with the solution set


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/StephanEwen/incubator-flink delta_no_solution_set

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #153
commit 145a5c2a6890f13edc557b0cc30e1722bd8c35cb
Author: Stephan Ewen <sewen@apache.org>
Date:   2014-10-13T18:24:35Z

    Fix various deprecation warnings in tests

commit c277435bda432d01a1774d9942f0300bd874bc02
Author: Stephan Ewen <sewen@apache.org>
Date:   2014-10-13T19:21:54Z

    [FLINK-1143] Allow delta iterations that do not join with the solution set


> Forced to use Solution Set
> --------------------------
>                 Key: FLINK-1143
>                 URL: https://issues.apache.org/jira/browse/FLINK-1143
>             Project: Flink
>          Issue Type: Bug
>          Components: JobManager
>            Reporter: Maximilian Alber
>            Priority: Minor
> When creating a step function for an iterate with delta function where the solution set
is not used, the compiler omits an error.
> In some cases this is not desirable. There should be at least a switch to disable this
> Exceptiontrace:
> org.apache.flink.compiler.CompilerException: Error: The step function does not reference
the solution set.
>  at org.apache.flink.compiler.PactCompiler$GraphCreatingVisitor.postVisit(PactCompiler.java:868)
>  at org.apache.flink.compiler.PactCompiler$GraphCreatingVisitor.postVisit(PactCompiler.java:622)
>  at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:283)
>  at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:202)
>  at org.apache.flink.api.common.operators.GenericDataSinkBase.accept(GenericDataSinkBase.java:286)
>  at org.apache.flink.api.common.Plan.accept(Plan.java:281)
>  at org.apache.flink.compiler.PactCompiler.compile(PactCompiler.java:517)
>  at org.apache.flink.compiler.PactCompiler.compile(PactCompiler.java:466)
>  at org.apache.flink.client.program.Client.getOptimizedPlan(Client.java:196)
>  at org.apache.flink.client.program.Client.getOptimizedPlan(Client.java:209)
>  at org.apache.flink.client.program.Client.run(Client.java:285)
>  at org.apache.flink.client.program.Client.run(Client.java:230)
>  at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:347)
>  at org.apache.flink.client.CliFrontend.run(CliFrontend.java:334)
>  at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1001)
>  at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1025)

This message was sent by Atlassian JIRA

View raw message