diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index 25b73e2ef9..193c9751e5 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -326,9 +326,7 @@ func (a *FlowableActivity) StartNormalize(
 
 		err = a.CatalogMirrorMonitor.UpdateEndTimeForCDCBatch(ctx, input.FlowConnectionConfigs.FlowJobName,
 			lastSyncBatchID)
-		if err != nil {
-			return nil, err
-		}
+		return nil, err
 	} else if err != nil {
 		return nil, err
 	}