From 15b021f1f4c73c08c0443fd9cae0221ae43877ba Mon Sep 17 00:00:00 2001 From: karthik Date: Mon, 14 Nov 2016 10:36:53 -0800 Subject: [PATCH] DRILL-5121 Fix for memory leak. Changes fieldVectorMap in ScanBatch to a CaseInsensitiveMap close apache/drill#690 --- .../java/org/apache/drill/exec/physical/impl/ScanBatch.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ScanBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ScanBatch.java index 43fabba9ec1..ad826686ac2 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ScanBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ScanBatch.java @@ -53,6 +53,7 @@ import org.apache.drill.exec.vector.NullableVarCharVector; import org.apache.drill.exec.vector.SchemaChangeCallBack; import org.apache.drill.exec.vector.ValueVector; +import org.apache.drill.common.map.CaseInsensitiveMap; import com.google.common.collect.Maps; @@ -67,8 +68,8 @@ public class ScanBatch implements CloseableRecordBatch { private final VectorContainer container = new VectorContainer(); /** Fields' value vectors indexed by fields' keys. */ - private final Map fieldVectorMap = - Maps.newHashMap(); + private final CaseInsensitiveMap fieldVectorMap = + CaseInsensitiveMap.newHashMap(); private int recordCount; private final FragmentContext context;