Github user HanumathRao commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r168338663
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/SingleMergeExchangePrel.java
---
@@ -93,6 +94,21 @@ public PhysicalOperator
getPhysicalOperator(PhysicalPlanCreator creator) throws
return creator.addMetadata(this, g);
}
+ /**
+ * This method creates a new OrderedMux exchange if mux operators are
enabled.
+ * @param child input to the new muxPrel or new SingleMergeExchange node.
+ * @param options options manager to check if mux is enabled.
+ */
+ @Override
+ public Prel constructMuxPrel(Prel child, OptionManager options) throws
RuntimeException {
+ Prel outPrel = child;
+ if
(options.getOption(PlannerSettings.ORDERED_MUX_EXCHANGE.getOptionName()).bool_val)
{
--- End diff --
@amansinha100 Thanks for the review . I have done the needed code changes
to fix it. Please let me know if anything is required.
---
