scio
scio copied to clipboard
Using sparkey largeHashIntersectByKey blocks pipeline on Dataflow v1
When using largeHashIntersectByKey, we've experienced pipelines hanging when running with dataflow default runnuer.
It seems that enabling the runner v2 unblocks the situation, but we should check why sparkey blocks worker progression.