numaflow
numaflow copied to clipboard
Flaky Unit Test TestNewInterStepDataForward/batch_forward_basic
=== RUN TestNewInterStepDataForward/batch_forward_basic
{"level":"info","ts":"2024-04-17T05:53:10.177109808Z","logger":"numaflow","caller":"forward/forward.go:136","msg":"Starting forwarder..."}
forward_test.go:1709: unexpected collecting result:
Diff:
--- metric output does not match expectation; want
+++ got:
@@ -1,5 +1,2 @@
-(bytes.Buffer) # HELP forwarder_ack_total Total number of Messages Acknowledged
-# TYPE forwarder_ack_total counter
-forwarder_ack_total{partition_name="from",pipeline="testPipeline",replica="0",vertex="testVertex",vertex_type="MapUDF"} 10
+(bytes.Buffer)
-
https://github.com/numaproj/numaflow/actions/runs/8716970620/job/23912020354?pr=1669