removes tablerows map

flow/connectors/eventhub/hub_batches.go

@@ -8,7 +8,6 @@ import (
 	"time"
 
 	azeventhubs "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs"
-	cmap "github.com/orcaman/concurrent-map/v2"
 	log "github.com/sirupsen/logrus"
 	"golang.org/x/sync/errgroup"
 )
@@ -122,7 +121,6 @@ func (h *HubBatches) flushAllBatches(
 	var numEventsPushed int32
 	g, gCtx := errgroup.WithContext(ctx)
 	g.SetLimit(int(maxParallelism))
-	tableNameRowsMapping := cmap.New[uint32]()
 	h.ForEach(func(tblName ScopedEventhub, eventBatch *azeventhubs.EventDataBatch) {
 		g.Go(func() error {
 			numEvents := eventBatch.NumEvents()
@@ -135,18 +133,12 @@ func (h *HubBatches) flushAllBatches(
 			log.WithFields(log.Fields{
 				"flowName": flowName,
 			}).Infof("pushed %d events to event hub: %s", numEvents, tblName)
-			tableNameRowsMapping.Upsert(tblName.ToString(), uint32(numEvents),
-				func(exist bool, rowCount uint32, newRows uint32) uint32 {
-					if !exist {
-						return newRows
-					}
-					return rowCount + newRows
-				})
 			return nil
 		})
 	})
 
-	log.Infof("[sendEventBatch] successfully sent %d events to event hub", numEventsPushed)
+	log.Infof("[sendEventBatch] successfully sent %d events in total to event hub",
+		numEventsPushed)
 	return g.Wait()
 }