diff options
| author | Vlad Rozov <vrozov@apache.org> | 2018-02-15 19:25:21 -0800 |
|---|---|---|
| committer | Vitalii Diravka <vitalii.diravka@gmail.com> | 2018-02-19 08:57:05 +0000 |
| commit | 894c0f58ecff11ce53ede696f2a82308ca8333d4 (patch) | |
| tree | 4d08cd7065b9deb1e7a4f0d9b811f1ac65cdd600 /contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr | |
| parent | 24a7acd440d29b7340a378306f339e1307892208 (diff) | |
DRILL-6164: Heap memory leak during parquet scan and OOM
closes #1122
Diffstat (limited to 'contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr')
| -rw-r--r-- | contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/MapRDBScanBatchCreator.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/MapRDBScanBatchCreator.java b/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/MapRDBScanBatchCreator.java index d9c8ce772..c15d9ba01 100644 --- a/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/MapRDBScanBatchCreator.java +++ b/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/MapRDBScanBatchCreator.java @@ -17,6 +17,7 @@ */ package org.apache.drill.exec.store.mapr.db; +import java.util.LinkedList; import java.util.List; import org.apache.drill.common.exceptions.ExecutionSetupException; @@ -31,13 +32,12 @@ import org.apache.drill.exec.store.mapr.db.binary.BinaryTableGroupScan; import org.apache.drill.exec.store.mapr.db.json.MaprDBJsonRecordReader; import com.google.common.base.Preconditions; -import com.google.common.collect.Lists; public class MapRDBScanBatchCreator implements BatchCreator<MapRDBSubScan> { @Override public ScanBatch getBatch(ExecutorFragmentContext context, MapRDBSubScan subScan, List<RecordBatch> children) throws ExecutionSetupException { Preconditions.checkArgument(children.isEmpty()); - List<RecordReader> readers = Lists.newArrayList(); + List<RecordReader> readers = new LinkedList<>(); for(MapRDBSubScanSpec scanSpec : subScan.getRegionScanSpecList()){ try { if (BinaryTableGroupScan.TABLE_BINARY.equals(subScan.getTableType())) { |