numaflow
numaflow copied to clipboard
numaproj
Kubernetes-native platform to run massively parallel data/streaming jobs
# Summary Max lag is 'Unavailable Now' because one of the sources doesn't have events flowing in while the other source has events. Ideally, what would be the best way...
**Describe the bug** In case of a join vertex with a single buffer, we will see the pending messages on the UI to be replicated for all edges. This can...
# Summary Currently, the paths to the example images are hardcoded in the build-push workflow and passed to the script. This means when adding a new or updating an existing...
Discussed and felt that having the operation (ie Map, Reduce, Transform) -> to be the action here. So keeping mapper, reducer, transformer would be consistent. And the the prefix can...
# Summary What change needs making? # Use Cases When would you use this? --- **Message from the maintainers**: If you wish to see this enhancement implemented please add a...
# Summary The current Server/Servicer structure directly ties a Servicer to the server. When dealing with more unary data types, this isn't a big deal as you can't do much...
**Describe the bug** This [file](https://github.com/numaproj/numaflow/blob/a3a67095e9c59b52fd1a913372e65e667db010ef/serving/backoff/src/lib.rs) only has 98 lines, but `codecov` reports it has `3422` lines of code missing test coverage. --- **Message from the maintainers**: Impacted by this bug?...
# Summary ISB TPS is directly proportional to latency between ISB pods. (e.g., 1ms = 1000 TPS). We will have to measure the latency post deployments to check for latency...
# Summary 1. How do we educate users to create a pipeline? What consists of a pipeline? 2. How many vertices would they need? > For source, when would they...
# Summary What change needs making? # Use Cases When would you use this? --- **Message from the maintainers**: If you wish to see this enhancement implemented please add a...