Naga

TDigest with custom equals and hashcode implementation

2

I have a use case to compare if 2 tdigest's are equal. Was wondering if it makes sense to override the equals and hashcode functions in MergingDigest class. Sample code...

possible to store in S3 and query via Athena

4

### Request I would like to know if it is possible to store CLP compressed data in S3 and query it through Athena using SQL? ### Possible implementation NA

Encountered error in sinkFn - CANCELLED: client cancelled

2

Update numaflow controller from `rc1` to `rc4`. I see this error message in the sink vertex. Sink Pods remained in Running State. Error in numa container ``` {"level":"error","ts":"2024-04-08T18:38:21.170233545Z","logger":"numaflow.Sink-processor","caller":"forward/forward.go:415","msg":"Retrying failed messages","pipeline":"kafka-test-pipeline-1","vertex":"custom-out","errors":{"gRPC...

In the User-defined source, I would like to have the ability to do a clean shutdown of the resources on Shutdown/Sigterm events. In the current interface, I do not see...

TLS handshake error: connection reset by peer or EOF

6

**Describe the bug** During performance test, I have enabled ambassador pods and my upstream service to scale up when it breaches the 60% cpu threshold. When the scale up events...