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