Running train crashes when the pipelines are collating results from running transform on the entire dataset.
Running train crashes when the pipelines are collating results from running transform on the entire dataset.