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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
