Fix shard recovery manager random interval

trinodb · Nov 17, 2016 · be6332c · be6332c
1 parent aa02058
commit be6332c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/presto-raptor/src/main/java/com/facebook/presto/raptor/storage/ShardRecoveryManager.java b/presto-raptor/src/main/java/com/facebook/presto/raptor/storage/ShardRecoveryManager.java
@@ -142,7 +142,9 @@ private void enqueueMissingShards()
     {
         missingShardExecutor.scheduleWithFixedDelay(() -> {
             try {
-                SECONDS.sleep(ThreadLocalRandom.current().nextInt(1, 30));
+                // jitter to avoid overloading database
+                long interval = missingShardDiscoveryInterval.roundTo(SECONDS);
+                SECONDS.sleep(ThreadLocalRandom.current().nextLong(1, interval));
                 for (ShardMetadata shard : getMissingShards()) {
                     stats.incrementBackgroundShardRecovery();
                     Futures.addCallback(