[jira] [Resolved] (FLINK-2534) Improve execution code in CompactingHashTable.java

["Stephan Ewen (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephan Ewen resolved FLINK-2534.
---------------------------------
    Resolution: Fixed

Fixed via 63ee34c5b894e2795e74a3c2aa3d5dc9ac2d5b88

Thank you for the contribution!

> Improve execution code in CompactingHashTable.java
> --------------------------------------------------
>
>                 Key: FLINK-2534
>                 URL: https://issues.apache.org/jira/browse/FLINK-2534
>             Project: Flink
>          Issue Type: Improvement
>          Components: Local Runtime
>    Affects Versions: 0.10
>            Reporter: Huang Wei
>             Fix For: 0.10
>
>   Original Estimate: 168h
>  Remaining Estimate: 168h
>
> I found some improved code in CompactingHashTable.java since this code will execute many times when flink runs.
> In my opinion, some codes in "for" and "while" can be optimized to reduce the times of execution and it is effective to increase the performance.
> For example, the code following:
> 'while(numBuckets % numPartitions != 0) {
> 			numBuckets++;
> 		}'
> can be optimized into a formula:
> numBuckets += numPartitions - (numBuckets % numPartitions);



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)