diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index 0965eb6b78..403df26da5 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -620,7 +620,6 @@ func CDCFlowWorkflow( } } } - workflow.GetInfo(ctx).GetCurrentHistorySize() if restart { if state.ActiveSignal == model.PauseSignal {