From 39857d7317bfbb1b4d734f30e2feaec4eed179d1 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Thu, 21 Sep 2023 14:05:20 -0700 Subject: [PATCH] update heartbeat for eventhub (#409) --- flow/connectors/eventhub/eventhub.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go index c54e32b72..b4d61f427 100644 --- a/flow/connectors/eventhub/eventhub.go +++ b/flow/connectors/eventhub/eventhub.go @@ -96,7 +96,7 @@ func (c *EventHubConnector) InitializeTableSchema(req map[string]*protos.TableSc } func (c *EventHubConnector) SyncRecords(req *model.SyncRecordsRequest) (*model.SyncResponse, error) { - shutdown := utils.HeartbeatRoutine(c.ctx, 1*time.Minute, func() string { + shutdown := utils.HeartbeatRoutine(c.ctx, 10*time.Second, func() string { return fmt.Sprintf("syncing records to eventhub with"+ " push parallelism %d and push batch size %d", req.PushParallelism, req.PushBatchSize)