[FLINK-2534] Improve execution code in CompactingHashTable.java

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0
• Fix Version/s: 0.10.0
• Component/s: Runtime / Task
• Assignee: Unassigned
• Reporter: Huang Wei
• Created: 17/Aug/15 03:02
• Updated: 17/Aug/15 12:16
• Resolved: 17/Aug/15 12:16

Description

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