When am trying to load run cumulative aggregation the tasks are being skipped. When i look inot executor logs i cant see any error.
RegardsKalyan
In your pipeline the filter anomaly_count=1 restricts outgoing data as it is non input field and no value present for it. Probably you are going for anomalyOutputColumn=true. You should try inspect to debug input output
