diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SplitOpTreeForDPP.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SplitOpTreeForDPP.java index 1348d8b..933d6af 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SplitOpTreeForDPP.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SplitOpTreeForDPP.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hive.ql.parse.spark; import java.util.ArrayList; -import java.util.HashSet; +import java.util.LinkedHashSet; import java.util.LinkedList; import java.util.List; import java.util.Set; @@ -140,7 +140,7 @@ public Object process(Node nd, Stack stack, NodeProcessorCtx procCtx, } //Find all pruningSinkSet in new roots - Set> sinkSet = new HashSet<>(); + Set> sinkSet = new LinkedHashSet<>(); for (Operator root : newRoots) { SparkUtilities.collectOp(sinkSet, root, SparkPartitionPruningSinkOperator.class); }