From 987ebc8af3a3d09a010d16012ae45b9f54ce94d5 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Mon, 20 Nov 2023 09:59:48 -0500 Subject: [PATCH] fix logging --- flow/connectors/eventhub/hub_batches.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/eventhub/hub_batches.go b/flow/connectors/eventhub/hub_batches.go index f0f04dafcf..47e6e232db 100644 --- a/flow/connectors/eventhub/hub_batches.go +++ b/flow/connectors/eventhub/hub_batches.go @@ -135,9 +135,9 @@ func (h *HubBatches) flushAllBatches( }) }) + err := g.Wait() log.Infof("[flush] successfully sent %d events in total to event hub", numEventsPushed) - err := g.Wait() // clear the batches after flushing them. h.Clear()