Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Drill >> mail # dev >> Review Request 17035: DRILL-334 Bit RPC socket split, Memory leak fixes - author: Jacques


+
Jason Altekruse 2014-01-17, 05:51
+
Jason Altekruse 2014-01-17, 05:52
Copy link to this message
-
Re: Review Request 17035: DRILL-334 Bit RPC socket split, Memory leak fixes - author: Jacques

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/17035/#review32132
-----------------------------------------------------------

exec/java-exec/src/main/java/org/apache/drill/exec/memory/TopLevelAllocator.java
<https://reviews.apache.org/r/17035/#comment60820>

    ?

exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java
<https://reviews.apache.org/r/17035/#comment60821>

    It seems to make sense to clear the sv?

exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/orderedpartitioner/OrderedPartitionRecordBatch.java
<https://reviews.apache.org/r/17035/#comment60822>

    ?

exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java
<https://reviews.apache.org/r/17035/#comment60825>

    I don't see you wait for the sendCount like you did for other operators?
    
    This looks like a pattern making sure all sending batches complete before close, perhaps this can be generalized a bit for easier reuse?

exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java
<https://reviews.apache.org/r/17035/#comment60823>

    sendAccounter.increment here?

exec/java-exec/src/main/java/org/apache/drill/exec/record/AbstractRecordBatch.java
<https://reviews.apache.org/r/17035/#comment60824>

    remove
- Timothy Chen
On Jan. 17, 2014, 5:51 a.m., Jason Altekruse wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/17035/
> -----------------------------------------------------------
>
> (Updated Jan. 17, 2014, 5:51 a.m.)
>
>
> Review request for drill.
>
>
> Bugs: 334
>     https://issues.apache.org/jira/browse/334
>
>
> Repository: drill-git
>
>
> Description
> -------
>
> Drill 334
>
>
> Diffs
> -----
>
>   common/src/main/java/org/apache/drill/common/config/DrillConfig.java ffbf910
>   exec/bufferl/src/main/java/io/netty/buffer/PooledUnsafeDirectByteBufL.java e5e1d20
>   exec/java-exec/pom.xml 2ffdae9
>   exec/java-exec/src/main/java/org/apache/drill/exec/ExecConstants.java 465813c
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/DistributedCache.java aed6cc2
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/DistributedMap.java b7595f9
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/DistributedMultiMap.java 886f122
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/HazelCache.java 9dd4373
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/LocalCache.java e6275c1
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoBufImpl.java d03eac8
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoBufWrap.java 448eecd
>   exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorAccessibleSerializable.java 656d07f
>   exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java 8ee9042
>   exec/java-exec/src/main/java/org/apache/drill/exec/client/DumpCat.java ef0b1e1
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/AccountingByteBuf.java PRE-CREATION
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java PRE-CREATION
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/AtomicRemainder.java PRE-CREATION
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/BufferAllocator.java 1584092
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/DirectBufferAllocator.java 77a251d
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/OutOfMemoryException.java PRE-CREATION
>   exec/java-exec/src/main/java/org/apache/drill/exec/memory/TopLevelAllocator.java PRE-CREATION
>   exec/java-exec/src/main/java/org/apache/drill/exec/metrics/SingleThreadNestedCounter.java 01385cf
>   exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java f75cf5f
+
Timothy Chen 2014-01-17, 06:22
+
Jacques Nadeau 2014-01-30, 18:03