beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paweł Kaczmarczyk (JIRA) <>
Subject [jira] [Commented] (BEAM-2455) Backlog size retrieval for Kinesis source
Date Sat, 17 Jun 2017 19:18:00 GMT


Paweł Kaczmarczyk commented on BEAM-2455:

[~davor] yes, that was my intention and I already have the implementation. Should I reformat
the whole Kinesis source code first to make it compliant with Beam code style?

> Backlog size retrieval for Kinesis source
> -----------------------------------------
>                 Key: BEAM-2455
>                 URL:
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-extensions
>            Reporter: Paweł Kaczmarczyk
> Implement backlog size retrieval for Kinesis source with the use of Amazon CloudWatch.
This will allow the runners to scale the amount of resources allocated to the pipeline.

This message was sent by Atlassian JIRA

View raw message