This is an automated email from the ASF dual-hosted git repository.

ibuenros pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 691d3cd  [GOBBLIN-809] Fix RateBasedLimitter factory to get double 
instead of long rate for initialization
691d3cd is described below

commit 691d3cd93035d1de8f1a4629326a0f3780d41156
Author: Aman Gupta <[email protected]>
AuthorDate: Wed Jun 19 14:38:57 2019 -0700

    [GOBBLIN-809] Fix RateBasedLimitter factory to get double instead of long 
rate for initialization
    
    Closes #2676 from aman1309/fix-double-ratelimiting
---
 .../src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
 
b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
index 05f3bc5..0f1bb12 100644
--- 
a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
+++ 
b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
@@ -53,7 +53,7 @@ public class RateBasedLimiter extends NonRefillableLimiter {
       if (!config.hasPath(QPS_KEY)) {
         throw new RuntimeException("Missing key " + QPS_KEY);
       }
-      return new RateBasedLimiter(config.getLong(QPS_KEY));
+      return new RateBasedLimiter(config.getDouble(QPS_KEY));
     }
   }
 

Reply via email to