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.
---