-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 6.4.0
-
Component/s: Code Generator
-
Labels:
-
Pull Request URL:
-
Compatibility:Major
Using ,DISTRIBUTED is ignored and therefore all rows are generated on the 1st node.
Example:
d := dataset([ {1},{1},{2},{3},{4},{8},{9}, ... {repeated 500 times) ], { unsigned r; }, DISTRIBUTED); p1 := PROJECT(d, TRANSFORM({d, unsigned4 n := 9999; }, SELF.n := thorlib.node(); SELF := LEFT)); p1(n!=0);
Gavin's comment:
It is because the type of activity created (TAKlinkedrawiterator) doesn’t have any flag to indicate it should be executed distributed.
Please can you open a jira, and I’ll work on it.