[jira] [Updated] (BEAM-13494) KinesisIO.read requires default rater limiter for low throughput shards

2024-11-23 Thread Anonymous (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-13494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Anonymous updated BEAM-13494:
-
Status: Triage Needed  (was: Resolved)

> KinesisIO.read requires default rater limiter for low throughput shards
> ---
>
> Key: BEAM-13494
> URL: https://issues.apache.org/jira/browse/BEAM-13494
> Project: Beam
>  Issue Type: Improvement
>  Components: io-java-aws, io-java-kinesis
>Reporter: Moritz Mack
>Assignee: Moritz Mack
>Priority: P2
> Fix For: 2.36.0
>
>  Time Spent: 1h 10m
>  Remaining Estimate: 0h
>
> In case Kinesis reads from a shared with no records available, the read loop 
> repeats unthrottled and exhausts API limits as well as CPU.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)


[jira] [Updated] (BEAM-13494) KinesisIO.read requires default rater limiter for low throughput shards

2021-12-22 Thread Alexey Romanenko (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-13494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Alexey Romanenko updated BEAM-13494:

Fix Version/s: 2.36.0
   Resolution: Fixed
   Status: Resolved  (was: Open)

> KinesisIO.read requires default rater limiter for low throughput shards
> ---
>
> Key: BEAM-13494
> URL: https://issues.apache.org/jira/browse/BEAM-13494
> Project: Beam
>  Issue Type: Improvement
>  Components: io-java-aws, io-java-kinesis
>Reporter: Moritz Mack
>Priority: P2
> Fix For: 2.36.0
>
>  Time Spent: 1h 10m
>  Remaining Estimate: 0h
>
> In case Kinesis reads from a shared with no records available, the read loop 
> repeats unthrottled and exhausts API limits as well as CPU.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)


[jira] [Updated] (BEAM-13494) KinesisIO.read requires default rater limiter for low throughput shards

2021-12-20 Thread Moritz Mack (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-13494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Moritz Mack updated BEAM-13494:
---
Status: Open  (was: Triage Needed)

> KinesisIO.read requires default rater limiter for low throughput shards
> ---
>
> Key: BEAM-13494
> URL: https://issues.apache.org/jira/browse/BEAM-13494
> Project: Beam
>  Issue Type: Improvement
>  Components: io-java-aws, io-java-kinesis
>Reporter: Moritz Mack
>Priority: P2
>
> In case Kinesis reads from a shared with no records available, the read loop 
> repeats unthrottled and exhausts API limits as well as CPU.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)