谷歌数据流工作连续失败：“管道坏了”

I've been using the same code for a long time it used to work but when I re-run our batch loader it gave error not enough disk space so I increased the disk size and ran again then I get Pipeline broken error like belowI've been using the same code for a long time i