commit 2f1f1df61f5945308707c6b6b8d2c30a366158bf
author JArod <jarodwen@gmail.com> Wed Oct 02 22:04:22 2013 -0700
committer JArod <jarodwen@gmail.com> Mon Nov 04 17:46:40 2013 -0500
tree 0feeddbabe8c28dd170052aac97ff4aba55a9e7e
parent 7d85059aff5bc7996170785c38c6644ca9041142

Fixed a bug on unclosed running aggregation runtime; fixed an issue on
two adjacent exchange operators (connectors) when duplicate sort
operator is removed. 

algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java

diff --git a/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java b/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java
index 810defc..11122d7 100644
--- a/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java
@@ -540,6 +540,10 @@
                 }
             }
             Mutable<ILogicalOperator> ci = op.getInputs().get(i);
+            if (((AbstractLogicalOperator) ci.getValue()).getOperatorTag() == LogicalOperatorTag.EXCHANGE) {
+                ci = ci.getValue().getInputs().get(0);
+                op.getInputs().set(i, ci);
+            }
             ExchangeOperator exchg = new ExchangeOperator();
             exchg.setPhysicalOperator(pop);
             setNewOp(ci, exchg, context);