Lakshmi Manasa Gaduputi created SAMZA-2732:
----------------------------------------------
Summary: [Elasticity] Add elasticityFactor into the TaskName when
elasticity is enabled
Key: SAMZA-2732
URL: https://issues.apache.org/jira/browse/SAMZA-2732
Project: Samza
Issue Type: Improvement
Reporter: Lakshmi Manasa Gaduputi
Assignee: Lakshmi Manasa Gaduputi
When elasticity is enabled, update the task name for
1. GroupByPartition SSP grouper from "Partition 0 1" to "Partition 0_1_2" where
0 is the input partition, 1 is the keyBucket and 2 is the elasticity factor.
2. GroupBySystemStreamPartition SSP grouper from "SystemStreamPartition
[systemA, streamB, 0, 1]" to "SystemStreamPartition [systemA, streamB, 0, 1]_2"
where 0 is the input partition, 1 is the keyBucket and 2 is the elasticity
factor.
elasticity is not supported for other SSP groupers.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
