diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index a10e544e2..1bb86dd53 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -561,7 +561,6 @@ func CDCFlowWorkflow( } } } - workflow.GetInfo(ctx).GetCurrentHistorySize() if restart || finished { for ctx.Err() == nil && (!finished || mainLoopSelector.HasPending()) {