diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/SharedWorkOptimizer.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/SharedWorkOptimizer.java index bc6d0bb..b60512b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/SharedWorkOptimizer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/SharedWorkOptimizer.java @@ -27,7 +27,6 @@ import java.util.HashSet; import java.util.Iterator; import java.util.LinkedHashSet; -import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Map.Entry; @@ -595,7 +594,7 @@ private static void gatherDPPTableScanOps( } } List> sortedTables = - new LinkedList<>(tableToTotalSize.entrySet()); + new ArrayList<>(tableToTotalSize.entrySet()); Collections.sort(sortedTables, Collections.reverseOrder( new Comparator>() { @Override @@ -635,7 +634,7 @@ private static void gatherReduceSinkOpsByInput(Multimap, StatsUtils.safeMult(op.getChildOperators().size(), size)); } List, Long>> sortedOps = - new LinkedList<>(opToTotalSize.entrySet()); + new ArrayList<>(opToTotalSize.entrySet()); Collections.sort(sortedOps, Collections.reverseOrder( new Comparator, Long>>() { @Override