diff --git a/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go b/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go index 96643875d496..3f505dc8fe7d 100644 --- a/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go +++ b/pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go @@ -590,9 +590,6 @@ func TestTenantStreamingCutoverOnSourceFailure(t *testing.T) { cutoverOutput := replicationtestutils.DecimalTimeToHLC(t, cutoverStr) require.Equal(c.T, cutoverTime, cutoverOutput) - // Resume ingestion. - c.DestSysSQL.Exec(t, fmt.Sprintf("RESUME JOB %d", ingestionJobID)) - // Ingestion job should succeed despite source failure due to the successful cutover jobutils.WaitForJobToSucceed(t, c.DestSysSQL, jobspb.JobID(ingestionJobID)) }