.../java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java index b445723..69d14c3 100644 --- a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java +++ b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java @@ -57,7 +57,6 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; -import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Map.Entry; @@ -272,9 +271,10 @@ public void alterTable(RawStore msdb, Warehouse wh, String dbname, while (partsToProcess > 0) { int batchEnd = Math.min(batchStart + partitionBatchSize, parts.size()); List partBatch = parts.subList(batchStart, batchEnd); - partsToProcess -= partBatch.size(); - batchStart += partBatch.size(); - List> partValues = new LinkedList<>(); + int partBatchSize = partBatch.size(); + partsToProcess -= partBatchSize; + batchStart += partBatchSize; + List> partValues = new ArrayList<>(partBatchSize); for (Partition part : partBatch) { partValues.add(part.getValues()); }