Kubernetes-native platform to run massively parallel data/streaming jobs

data-processing hacktoberfest k8s kubernetes map-reduce pipeline stream-processing
5 Open Issues Need Help Last updated: Jun 19, 2025

Open Issues Need Help

View All on GitHub
good first issue help wanted area/controller

Kubernetes-native platform to run massively parallel data/streaming jobs

Go
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing

AI Summary: The Numaflow SQS extension uses a deprecated AWS Smithy mocks library. The task is to update the extension to use the stable `aws-smithy-mocks` crate instead of the deprecated `aws-smithy-mocks-experimental` crate, resolving the deprecation warning.

Complexity: 3/5
good first issue help wanted rust

Kubernetes-native platform to run massively parallel data/streaming jobs

Go
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing

AI Summary: Resolve an inconsistency in the Numaflow project where the `tags` field in `edge:conditions` is mandatory in the Rust backend but optional in the Go backend. This requires unifying the behavior across both backends, ensuring consistent validation and handling of the `tags` field in edge specifications.

Complexity: 4/5
bug good first issue

Kubernetes-native platform to run massively parallel data/streaming jobs

Go
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing

AI Summary: The issue describes a bug in the Numaflow UI where the health filter doesn't correctly filter unhealthy pipelines. The task is to debug and fix this filtering issue in the UI, ensuring that only pipelines with the selected health status are displayed. This involves investigating the filtering logic within the UI codebase and correcting any errors that prevent the proper filtering of unhealthy pipelines.

Complexity: 4/5
bug good first issue area/ui

Kubernetes-native platform to run massively parallel data/streaming jobs

Go
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing

AI Summary: The Numaflow Rust Generator source needs to be fixed to decode base64 encoded values in the `valueBlob` field of its configuration. Currently, it sends the base64 encoded string instead of the decoded value to the Pulsar sink. The fix involves modifying the `components.rs` file to decode the base64 string before sending it.

Complexity: 3/5
bug good first issue area/source rust

Kubernetes-native platform to run massively parallel data/streaming jobs

Go
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing