Skip to content

Commit

Permalink
better logs
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Sep 28, 2023
1 parent 7d896ea commit bd0191f
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions flow/connectors/eventhub/eventhub.go
Original file line number Diff line number Diff line change
Expand Up @@ -280,8 +280,7 @@ func (c *EventHubConnector) sendEventBatch(
atomic.AddInt32(&numEventsPushed, numEvents)
log.WithFields(log.Fields{
"flowName": flowName,
}).Infof("pushed %d events to event hub: %s",
numEventsPushed, tblName)
}).Infof("pushed %d events to event hub: %s", numEvents, tblName)
rowCount, ok := tableNameRowsMapping.Get(tblName.ToString())
if !ok {
rowCount = uint32(0)
Expand Down

0 comments on commit bd0191f

Please sign in to comment.