[BEAM-12634] JmsIO autoscaling ability

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.31.0
• Fix Version/s: 2.34.0
• Component/s: io-java-jms
• Assignee: Vincent BALLADA
• Reporter: Vincent BALLADA
• Created: 19/Jul/21 09:09
• Updated: 10/Sep/21 17:29
• Resolved: 10/Sep/21 17:29

Description

JmsIO doesn't implement the getSplitBacklogBytes or getTotalBacklogBytes method, there is no backlog estimate.

Dataflow runner autoscaler is not able to allocate workers depending on the backlog size (scale down and up).

As a consequence autoscaling cannot be used, a fix number of workers must be configured.

Issue Links

• links to: GitHub Pull Request #15464