Skip to content

Commit

Permalink
Eventhub Normalize Fix (#370)
Browse files Browse the repository at this point in the history
`res` (result of normalize flow) in the below call is nil in case of
Eventhub so we make it a non-nil:
```Go
err = a.CatalogMirrorMonitor.UpdateEndTimeForCDCBatch(ctx, input.FlowConnectionConfigs.FlowJobName,
		res.EndBatchID)
```
  • Loading branch information
Amogh-Bharadwaj authored Sep 1, 2023
1 parent 09f26f3 commit 3f48101
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
6 changes: 5 additions & 1 deletion flow/connectors/eventhub/eventhub.go
Original file line number Diff line number Diff line change
Expand Up @@ -310,7 +310,11 @@ func (c *EventHubConnector) SetupNormalizedTables(

func (c *EventHubConnector) NormalizeRecords(req *model.NormalizeRecordsRequest) (*model.NormalizeResponse, error) {
log.Infof("normalization for event hub is a no-op")
return nil, nil
return &model.NormalizeResponse{
EndBatchID: 0,
StartBatchID: 0,
Done: true,
}, nil
}

// cleanup
Expand Down
2 changes: 1 addition & 1 deletion flow/connectors/postgres/cdc.go
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@ func (p *PostgresCDCSource) consumeStream(
if err != nil {
return nil, fmt.Errorf("SendStandbyStatusUpdate failed: %w", err)
}
log.Debugf("Sent Standby status message")
log.Infof("Sent Standby status message")
nextStandbyMessageDeadline = time.Now().Add(standbyMessageTimeout)
}

Expand Down

0 comments on commit 3f48101

Please sign in to comment.