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