Repository: hadoop Updated Branches: refs/heads/YARN-6592 32620a129 -> b9f0e942f (forced update)
HADOOP-15023. ValueQueue should also validate (int) (lowWatermark * numValues) > 0 on construction. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/b1941b20 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/b1941b20 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/b1941b20 Branch: refs/heads/YARN-6592 Commit: b1941b200d6b4fa6a7891421c0a1e212cad3d6eb Parents: fac72ee Author: Xiao Chen <x...@apache.org> Authored: Wed Nov 15 16:43:25 2017 -0800 Committer: Xiao Chen <x...@apache.org> Committed: Wed Nov 15 16:44:06 2017 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/b1941b20/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java index 8411ffb..1ddd8a3 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java @@ -224,6 +224,9 @@ public class ValueQueue <E> { Preconditions.checkArgument(numValues > 0, "\"numValues\" must be > 0"); Preconditions.checkArgument(((lowWatermark > 0)&&(lowWatermark <= 1)), "\"lowWatermark\" must be > 0 and <= 1"); + final int watermarkValue = (int) (numValues * lowWatermark); + Preconditions.checkArgument(watermarkValue > 0, + "(int) (\"numValues\" * \"lowWatermark\") must be > 0"); Preconditions.checkArgument(expiry > 0, "\"expiry\" must be > 0"); Preconditions.checkArgument(numFillerThreads > 0, "\"numFillerThreads\" must be > 0"); @@ -243,8 +246,7 @@ public class ValueQueue <E> { throws Exception { LinkedBlockingQueue<E> keyQueue = new LinkedBlockingQueue<E>(); - refiller.fillQueueForKey(keyName, keyQueue, - (int)(lowWatermark * numValues)); + refiller.fillQueueForKey(keyName, keyQueue, watermarkValue); return keyQueue; } }); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
