Github user chaithu14 commented on the issue:
https://github.com/apache/apex-core/pull/359
@vrozov Can the definePartitions() return the current partition ? If yes,
then there might be an issue in redoPartition().
From the above example, for the logical operator C, current partition size
is 2 and new partition size is 3 which consists of current partitions {C1, C2}.
Output port of C1 (or) C2 maps to input port of Unifier.
If the physical dag as below:
A1->B1->C1->Aggregator.
Current partition size = 1
A is repartitioned to 2 then physical dag as below:
A1->B1->C1->
U -> Aggregator
A2->B2->C2->
new partition size = 2
Here, in the initial launch, Output of C1 maps to input of Aggregator and
in after repartition, output of C1 maps to unifier. The mapping of current
partition (A1) has changed in after repartition. I think, this case is not
covered in redopartitions().
Please correct it, if i am wrong.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
