diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index 7f6b0af12e..a4e8725df2 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -379,6 +379,7 @@ func CDCFlowWorkflowWithConfig( defer workflow.CompleteSession(syncSessionCtx) sessionInfo := workflow.GetSessionInfo(syncSessionCtx) + w.logger.Info("sync session started", "sessionID", sessionInfo.SessionID) syncCtx := workflow.WithActivityOptions(syncSessionCtx, workflow.ActivityOptions{ StartToCloseTimeout: 72 * time.Hour, HeartbeatTimeout: time.Minute,