Vigith Maurice
Vigith Maurice
2 asks, can be implemented in separate PRs - [ ] Today, the UI selects numa container by default, but it should be selecting user-container. - [ ] It should...
Debugging through UI is not helpful, especially when there are pod restarts or failing containers. We should show the following - [ ] pod restart count - [ ] restart...
# Summary source-transformer might return -1 watermark for a message in a batch. since we also take min of watermarks, we will end up publishing -1 watermark which will be...
Document event_time and how it is affected by reduce.
We have a single WAL file per partition (which translates to a window). We need to split the WAL files to increase the bootup speed.
Today `BufferWriter.Write` retries on error, in udSink if the user mistakenly sets `response.Failure` for a message then we will end up in infinite retry. As a data platform our strategy...
```[tasklist] ### Tasks - [ ] https://github.com/numaproj/numaflow/pull/1904 - [ ] https://github.com/numaproj/numaflow/issues/1908 - [ ] emit basic metrics - [x] lag reader and pending - [x] integrate with soucer-sinker numaflow-model -...
Run an endurance test such that we won't have an OOM for the following distribution of the payload. TPS = 20K (5 partitions) 1% 64MB 2% 32MB 2% 48MB 15%...
Run an endurance test such that we won't have an OOM for the following distribution of the payload. TPS = 20K (5 partitions) 1% 64MB 2% 32MB 2% 48MB 15%...