[
https://issues.apache.org/jira/browse/FLINK-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1143.
---------------------------------
Resolution: Fixed
Fix Version/s: 0.7-incubating
Assignee: Stephan Ewen
Fixed via bf20591b10373d2e742c0e49b8a9506f530e296e
> 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
> Assignee: Stephan Ewen
> Priority: Minor
> Fix For: 0.7-incubating
>
>
> 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 reinforcement.
> 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
(v6.3.4#6332)
