From e94a26adddb535221fda6c6d797211b4c57df380 Mon Sep 17 00:00:00 2001 From: alingse Date: Sun, 26 May 2024 23:15:28 +0800 Subject: [PATCH] fix: fix miss makezero bug Signed-off-by: alingse --- outputs/stream/internally_consistent_output_stream_wrapper.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/outputs/stream/internally_consistent_output_stream_wrapper.go b/outputs/stream/internally_consistent_output_stream_wrapper.go index 21509888..41995347 100644 --- a/outputs/stream/internally_consistent_output_stream_wrapper.go +++ b/outputs/stream/internally_consistent_output_stream_wrapper.go @@ -23,7 +23,7 @@ func (node *InternallyConsistentOutputStreamWrapper) Run(ctx ExecutionContext, p afterWatermarkCount++ } } - newPending := make([]Record, afterWatermarkCount) + newPending := make([]Record, 0, afterWatermarkCount) for i := range pending { if pending[i].EventTime.After(watermark) { newPending = append(newPending, pending[i])