You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by kh...@apache.org on 2023/02/17 10:12:20 UTC
[pinot] branch master updated: Handle interrupted exception during Kinesis rate limit (#10297)
This is an automated email from the ASF dual-hosted git repository.
kharekartik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 4e0afef532 Handle interrupted exception during Kinesis rate limit (#10297)
4e0afef532 is described below
commit 4e0afef5320c799e3a4083bb0594de1427ac70da
Author: Kartik Khare <kh...@gmail.com>
AuthorDate: Fri Feb 17 15:42:10 2023 +0530
Handle interrupted exception during Kinesis rate limit (#10297)
---
.../org/apache/pinot/plugin/stream/kinesis/KinesisConsumer.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumer.java b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumer.java
index 3ded54ec8f..0fd889d1d4 100644
--- a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumer.java
+++ b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumer.java
@@ -173,7 +173,12 @@ public class KinesisConsumer extends KinesisConnectionHandler implements Partiti
}
if (currentWindowRequests >= _rpsLimit) {
- Thread.sleep(SLEEP_TIME_BETWEEN_REQUESTS);
+ try {
+ Thread.sleep(SLEEP_TIME_BETWEEN_REQUESTS);
+ } catch (InterruptedException e) {
+ LOGGER.debug("Sleep interrupted while rate limiting Kinesis requests", e);
+ break;
+ }
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org