Yashash H L

Flaky reduce-two-e2e and idle-source-e2e

2

reduce-two-e2e - https://github.com/numaproj/numaflow/actions/runs/9034959063/job/24828692966?pr=1723 idle-source-e2e - https://github.com/numaproj/numaflow/actions/runs/9026274446/job/24803315933

https://github.com/numaproj/numaflow/blob/3225b730d8cdd5c855da9b119cb27fe9f8112f5b/pkg/sinks/udsink/sink.go#L73 https://github.com/numaproj/numaflow/blob/3225b730d8cdd5c855da9b119cb27fe9f8112f5b/pkg/sinks/forward/forward.go#L258

UDF Container Restart not Triggering Numa Container Restart

4

related to https://github.com/numaproj/numaflow/issues/1592

Seeing duplicate messages in user defined source

2

``` Duplicate message - AAAAAJexQqI=-52-input-0 - 419895504 ``` we occasionally see around 10 per second.

* The home page could display the Numaflow Server version it is currently running on. * The pipeline page could display the Numaflow controller version being used by the pipeline.

``` === 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...

Buffer Usage Calculation and ISB Writing Race Condition: Potential Data Loss in High-Throughput Pipelines

5

https://github.com/numaproj/numaflow/issues/1551 https://github.com/numaproj/numaflow/issues/1551#issuecomment-1991223266