Skip to content

Commit

Permalink
[FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleIn…
Browse files Browse the repository at this point in the history
…putPlanNode

WorksetIterationNode#instantiate loops over all solution and work set
candidates. Since the solution set reference is modified in place when
the predecessor node can be used in its place, swith this variable to
the inner loop.

This closes apache#3563
  • Loading branch information
greghogan committed Mar 31, 2017
1 parent 2313a74 commit 43158a8
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -431,8 +431,8 @@ else if (report == FeedbackPropertiesMeetRequirementsReport.NOT_MET) {
LocalProperties lp = LocalProperties.EMPTY.addUniqueFields(this.solutionSetKeyFields);

// take all combinations of solution set delta and workset plans
for (PlanNode solutionSetCandidate : solutionSetDeltaCandidates) {
for (PlanNode worksetCandidate : worksetCandidates) {
for (PlanNode worksetCandidate : worksetCandidates) {
for (PlanNode solutionSetCandidate : solutionSetDeltaCandidates) {
// check whether they have the same operator at their latest branching point
if (this.singleRoot.areBranchCompatible(solutionSetCandidate, worksetCandidate)) {

Expand Down

0 comments on commit 43158a8

Please sign in to comment.