flush DeleteRecord batch before WriteInsert

maaarcelino · maaarcelino · commit 023ced968c9b · 2025-05-19T11:50:05.000+02:00
diff --git a/writers/batchwriter/batchwriter.go b/writers/batchwriter/batchwriter.go
@@ -313,6 +313,9 @@ func (w *BatchWriter) Write(ctx context.Context, msgs <-chan message.WriteMessag
 			if err := w.flushDeleteStaleTables(ctx); err != nil {
 				return err
 			}
+			if err := w.flushDeleteRecordTables(ctx); err != nil {
+				return err
+			}
 			if err := w.startWorker(ctx, m); err != nil {
 				return err
 			}

Original file line number	Diff line number	Diff line change
`@@ -313,6 +313,9 @@ func (w *BatchWriter) Write(ctx context.Context, msgs <-chan message.WriteMessag`
`313`	`313`	`if err := w.flushDeleteStaleTables(ctx); err != nil {`
`314`	`314`	`return err`
`315`	`315`	`}`
	`316`	`+ if err := w.flushDeleteRecordTables(ctx); err != nil {`
	`317`	`+ return err`
	`318`	`+ }`
`316`	`319`	`if err := w.startWorker(ctx, m); err != nil {`
`317`	`320`	`return err`
`318`	`321`	`}`