From 7216f9a2e227dd1156cdd38ce8007306dc898665 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Sun, 22 Oct 2023 18:10:51 -0400
Subject: [PATCH] truncate errors

---
 flow/workflows/cdc_flow.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
index 8029a10408..064bb4c1b6 100644
--- a/flow/workflows/cdc_flow.go
+++ b/flow/workflows/cdc_flow.go
@@ -102,6 +102,16 @@ func (s *CDCFlowState) TruncateProgress() {
 	if len(s.NormalizeFlowStatuses) > 10 {
 		s.NormalizeFlowStatuses = s.NormalizeFlowStatuses[len(s.NormalizeFlowStatuses)-10:]
 	}
+
+	if s.SyncFlowErrors != nil {
+		fmt.Println("SyncFlowErrors: ", s.SyncFlowErrors)
+		s.SyncFlowErrors = nil
+	}
+
+	if s.NormalizeFlowErrors != nil {
+		fmt.Println("NormalizeFlowErrors: ", s.NormalizeFlowErrors)
+		s.NormalizeFlowErrors = nil
+	}
 }
 
 func (s *CDCFlowState) SendWALHeartbeat(ctx workflow.Context, cfg *protos.FlowConnectionConfigs) error {