v1.8.2
What's Changed
- feat(sqs): utilize nack options for SQS by @AyushSrivastava1818 in #3557
- feat: introduce a generic map for per message nack options by @vaibhavtiwari33 in #3539
- feat: metrics to track nacks by @vaibhavtiwari33 in #3534
- fix: apply retention gate when deleting frozen gc files after compaction #3533 by @yhl25 in #3533
- feat(pulsar): support consumer dead letter policy and redelivery delay by @AyushSrivastava1818 in #3532
- feat: add securityContext to monitor container #3519 by @vigith in #3519
- chore: introduce additional unhealthy waiting statuses by @vaibhavtiwari33 in #3517
- fix(UI): source transformer node in pipeline #3508 by @suryapratap-01 in #3508
- fix(UI): dynamic monovertex dimension for cleaner UI #3505 by @suryapratap-01 in #3505
- fix: return detailed vertex status message when unhealthy by @AyushSrivastava1818 in #3502
- fix: drain closed accumulator window on re-opened key by @vaibhavtiwari33 in #3494
- feat: surface OOM (and other) reasons as free-form text by @vaibhavtiwari33 in #3481
- fix: cleanup wal on eof in accumulator #3461 by @vaibhavtiwari33 in #3461
- feat: end to end wiring for per msg nack option by @vaibhavtiwari33 in #3455
Installation
kubectl create namespace numaflow-system
# Install numaflow controller and UI
kubectl apply -n numaflow-system -f https://github.com/numaproj/numaflow/releases/download/v1.8.2/install.yaml
# Install validating webhook (Optional)
kubectl apply -n numaflow-system -f https://github.com/numaproj/numaflow/releases/download/v1.8.2/validating-webhook-install.yaml
Full Changelog: v1.8.1...v1.8.2