This is an automated email from the ASF dual-hosted git repository. aromanenko pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0ef6d4b Merge pull request #16316 Benchmark and optimize Python RowCoder add 9e87d11 [BEAM-13494] Avoid draining Kinesis API limits & CPU when reading from empty or low throughput shard add 0d0278f Merge pull request #16288: [BEAM-13494] Avoid draining Kinesis API limits & CPU when reading from empty or low throughput shard No new revisions were added by this update. Summary of changes: .../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 2 +- .../io/aws2/kinesis/RateLimitPolicyFactory.java | 76 ++++++++++++++++++++ .../aws2/kinesis/RateLimitPolicyFactoryTest.java | 81 ++++++++++++++++++++++ .../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 2 +- .../sdk/io/kinesis/RateLimitPolicyFactory.java | 76 ++++++++++++++++++++ .../sdk/io/kinesis/RateLimitPolicyFactoryTest.java | 64 +++++++++++++++-- 6 files changed, 295 insertions(+), 6 deletions(-) create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/kinesis/RateLimitPolicyFactoryTest.java