Skip to content

Commit 9a2231a

Browse files
authored
normalize: update normalizeResponses even when connector does not implement normalization (#3637)
user reported sync stalling out with s3 destination
1 parent f1a4f71 commit 9a2231a

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

flow/activities/flowable_core.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -637,6 +637,7 @@ func (a *FlowableActivity) startNormalize(
637637
config.DestinationName,
638638
)
639639
if errors.Is(err, errors.ErrUnsupported) {
640+
normalizeResponses.Update(batchID)
640641
return monitoring.UpdateEndTimeForCDCBatch(ctx, a.CatalogPool, config.FlowJobName, batchID)
641642
} else if err != nil {
642643
return a.Alerter.LogFlowError(ctx, config.FlowJobName, fmt.Errorf("failed to get normalize connector: %w", err))

0 commit comments

Comments
 (0)