Hi, I am trying to explore affinity feature in Apex. For this, I am using pi-demo application from apex-malhar. As per the affinity document <https://github.com/apache/apex-core/blob/master/docs/application_development.md>, I have updated the demo application's properties file as follows:
<property> <name>dt.application.AffinityRulesSampleApplication.attr.AFFINITY_RULES_SET</name> <value> { "affinityRules": [ { "operatorsList": [ "rand", "picalc" ], "locality": "NODE_LOCAL", "type": "AFFINITY", "relaxLocality": false } ] } </value> </property> After launching the demo application, I don't see containers for operator "rand" and "picalc" on the same node. Although it's working fine when I set the rule from application code. Can anyone please help me here? Thanks, Akshay