----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25795/ -----------------------------------------------------------
Review request for drill and Steven Phillips. Repository: drill-git Description ------- Provides memory planning at the fragment level. Applies a dynamic limit per fragment. Allows certain operators to bypass the fragment limit. Diffs ----- exec/java-exec/src/main/java/io/netty/buffer/FakeAllocator.java bc69577 exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java d11f224 exec/java-exec/src/main/java/org/apache/drill/exec/memory/AtomicRemainder.java 263caa0 exec/java-exec/src/main/java/org/apache/drill/exec/memory/BufferAllocator.java 8971eea exec/java-exec/src/main/java/org/apache/drill/exec/memory/TopLevelAllocator.java a8e8a28 exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java a888ea7 exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorContext.java 54edf88 exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/BaseRootExec.java c2c3144 exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ScanBatch.java 2712e27 exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/SingleSenderCreator.java 352deae exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/broadcastsender/BroadcastSenderRootExec.java d09559d exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/mergereceiver/MergingRecordBatch.java 29fd80f exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java 6ff0418 exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/unorderedreceiver/UnorderedReceiverBatch.java 8e7d9c6 exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/xsort/ExternalSortBatch.java 52249e9 exec/java-exec/src/main/java/org/apache/drill/exec/record/AbstractRecordBatch.java e8ad311 exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java 5a6ba80 exec/java-exec/src/main/java/org/apache/drill/exec/work/batch/SpoolingRawBatchBuffer.java c7527d5 exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/QueryManager.java 083dd95 exec/java-exec/src/test/java/org/apache/drill/exec/memory/TestAllocators.java PRE-CREATION exec/java-exec/src/test/resources/physical_allocator_test.json PRE-CREATION Diff: https://reviews.apache.org/r/25795/diff/ Testing ------- Added new unit test. Ran all unit tests. TPC-H distributed tests are particularly good tests for this change. Thanks, Parth Chandra
