numaflow
numaflow copied to clipboard
Flaky TestSimpleReducePipelineFailOverUsingWAL
https://github.com/numaproj/numaflow/actions/runs/10520016243/job/29148330229
https://github.com/numaproj/numaflow/actions/runs/10535815057/job/29195277884
https://github.com/numaproj/numaflow/actions/runs/10548644243/job/29222799034
Could be because when the test case killed the pod, pod didn't get gracefully shutdown, causing WAL in a bad state. Consider adding logs to the WAL close method and check. func (s *unalignedWAL) Close()