From bd0191f36b9b32c8d893add3a17418f298eab422 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Thu, 28 Sep 2023 15:13:10 -0400
Subject: [PATCH] better logs

---
 flow/connectors/eventhub/eventhub.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
index 345f75643b..35c1e6ee38 100644
--- a/flow/connectors/eventhub/eventhub.go
+++ b/flow/connectors/eventhub/eventhub.go
@@ -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)