diff --git a/flow/activities/flowable_core.go b/flow/activities/flowable_core.go
index bb75daa6da..4d1523379f 100644
--- a/flow/activities/flowable_core.go
+++ b/flow/activities/flowable_core.go
@@ -144,6 +144,7 @@ func syncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDCSyncCon
 		return dstConn.GetLastOffset(ctx, config.FlowJobName)
 	}()
 	if err != nil {
+		a.Alerter.LogFlowError(ctx, flowName, err)
 		return nil, err
 	}