Add drain support for Dataflow and Flink #27451

Job	Run time
${{ matrix.job_name }} (${{ matrix.job_phrase }} ${{ matrix.python_version }})	-1s
	-1s

Provide feedback