[
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)
