在数据流作业中的所有步骤完成后删除 bigquery table

Delete a bigquery table after all the steps in dataflow job have completed

有没有办法只有在批处理数据流管道中的所有步骤都成功后才能删除 bigquerytable?

您可以使用 DataflowPipelineJob.waitToFinish(...) to wait for your job to finish, check that the returned state was DONE, and then use the BigQuery API to delete table。