numaproj/numaflow issues and pull requests

#1709 - chore: bypass transformer call if UDTransformer is not defined

Pull Request - State: closed - Opened by ayildirim21 10 months ago - 4 comments

#1708 - chore: Refactor Source to Avoid Implementing Forwarder Interface

Pull Request - State: closed - Opened by yhl25 10 months ago - 2 comments

#1707 - feat: Stream mapper implementation of `MapStreamBatchFn`. Fixes #1688

Pull Request - State: closed - Opened by magelisk 10 months ago - 1 comment

#1706 - chore: avoid no-ack when ctx is canceled

Pull Request - State: closed - Opened by yhl25 10 months ago

#1705 - chore: version compatibility docs

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#1704 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] 10 months ago

#1703 - chore: skip sdk compatibility check if server info does not contain sdk version

Pull Request - State: closed - Opened by ayildirim21 10 months ago - 1 comment

#1702 - chore: UDS based multiproc server

Pull Request - State: closed - Opened by kohlisid 10 months ago

#1701 - Fix UI test cases and enable CI

Issue - State: open - Opened by whynowy 10 months ago
Labels: bug, testing, area/ui

#1700 - docs: add references to numaproj-contrib

Pull Request - State: closed - Opened by KeranYang 10 months ago

#1699 - create dynamic dashboards when new pipeline created/updated

Issue - State: closed - Opened by mshakira 10 months ago - 1 comment
Labels: enhancement, wontfix

#1698 - chore: refactor sideinput and redis sink e2e

Pull Request - State: closed - Opened by ayildirim21 10 months ago - 1 comment

#1697 - New metrics to show vertex level processing lag

Issue - State: open - Opened by jy4096 10 months ago
Labels: enhancement, opex

#1696 - chore: refactor on sdk client packages

Pull Request - State: closed - Opened by whynowy 10 months ago

#1695 - inbuilt JetStream source

Issue - State: closed - Opened by vigith 10 months ago - 2 comments
Labels: enhancement, area/source

#1694 - doc: add "nav" for fallback-sink

Pull Request - State: closed - Opened by vigith 10 months ago

#1693 - chore: deprecate kustomize patchesstrategicmerge

Pull Request - State: closed - Opened by whynowy 10 months ago

#1692 - chore(deps): bump golang.org/x/net from 0.22.0 to 0.23.0

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago
Labels: dependencies, go

#1691 - doc: Fallback Sink

Pull Request - State: closed - Opened by yhl25 10 months ago

#1690 - Docs: Reduce Streaming

Issue - State: closed - Opened by yhl25 10 months ago

#1689 - doc: reduce streaming

Pull Request - State: closed - Opened by yhl25 10 months ago

#1688 - Batch Mapping & Sink

Issue - State: closed - Opened by magelisk 10 months ago - 10 comments
Labels: enhancement

#1687 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] 10 months ago

#1686 - Add documentation to maintain historical version config mappings

Issue - State: open - Opened by ayildirim21 10 months ago - 1 comment
Labels: enhancement, area/sdk

#1685 - Move to new Jetstream API

Issue - State: open - Opened by kohlisid 10 months ago
Labels: enhancement, area/isb-jetstream

#1684 - chore: add back python e2e

Pull Request - State: closed - Opened by kohlisid 10 months ago

#1683 - chore: add version compatibility check

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#1682 - e2e tests for fallback

Issue - State: closed - Opened by vigith 10 months ago
Labels: testing

#1681 - chore: Fallback Sink E2E test

Pull Request - State: closed - Opened by yhl25 10 months ago

#1680 - chore: debug flaky reduce-e2e

Pull Request - State: closed - Opened by yhl25 10 months ago

#1679 - Flaky Unit Test TestNewInterStepDataForward/batch_forward_basic

Issue - State: closed - Opened by yhl25 10 months ago - 1 comment
Labels: bug

#1679 - Flaky Unit Test TestNewInterStepDataForward/batch_forward_basic

Issue - State: open - Opened by yhl25 10 months ago
Labels: bug

#1678 - feat: add batch reading for Jetstream

Pull Request - State: open - Opened by kohlisid 10 months ago

#1678 - feat: add batch reading for Jetstream

Pull Request - State: open - Opened by kohlisid 10 months ago

#1678 - feat: add batch reading for Jetstream

Pull Request - State: closed - Opened by kohlisid 10 months ago - 3 comments

#1677 - Ordered Processing

Issue - State: open - Opened by vigith 10 months ago
Labels: enhancement, nice-to-have

#1677 - Ordered Processing

Issue - State: open - Opened by vigith 10 months ago
Labels: enhancement, nice-to-have

#1676 - Fallback Sink for Python SDK

Issue - State: closed - Opened by kohlisid 10 months ago - 1 comment

#1676 - Fallback Sink for Python SDK

Issue - State: closed - Opened by kohlisid 10 months ago - 1 comment

#1676 - Fallback Sink for Python SDK

Issue - State: closed - Opened by kohlisid 10 months ago - 1 comment

#1675 - Batching with Timeout not working as expected

Issue - State: open - Opened by kohlisid 10 months ago - 1 comment
Labels: bug, area/isb-jetstream

#1674 - Re-arrange e2e test images source code

Issue - State: closed - Opened by KeranYang 10 months ago
Labels: enhancement, area/sdk

#1673 - fix: version downgrade for monaco-editor

Pull Request - State: closed - Opened by veds-g 10 months ago

#1673 - fix: version downgrade for monaco-editor

Pull Request - State: open - Opened by veds-g 10 months ago

#1673 - fix: version downgrade for monaco-editor

Pull Request - State: open - Opened by veds-g 10 months ago

#1672 - Docs for CORS

Issue - State: open - Opened by whynowy 10 months ago
Labels: documentation, enhancement

#1672 - Docs for CORS

Issue - State: open - Opened by whynowy 10 months ago
Labels: documentation, enhancement

#1671 - fix: routing fixes

Pull Request - State: closed - Opened by veds-g 10 months ago

#1670 - Numaflow UI showing wrong health status for ISB

Issue - State: open - Opened by igrishi 10 months ago
Labels: bug

#1669 - feat: Fallback Sink

Pull Request - State: closed - Opened by yhl25 10 months ago

#1668 - add fallback-sink to sinker

Issue - State: closed - Opened by vigith 10 months ago
Labels: area/sink

#1667 - chore: kustomization cofigurations support fallback sink

Pull Request - State: closed - Opened by whynowy 10 months ago - 1 comment

#1666 - use container-type ENV to name server-info and UDS file

Issue - State: closed - Opened by vigith 10 months ago - 2 comments
Labels: area/controller

#1665 - ReduceStreamer: `Server info file /var/run/numaflow/reducer-server-info is not ready`

Issue - State: closed - Opened by th0ger 10 months ago - 2 comments
Labels: bug

#1664 - feat: controller change for fallback sink

Pull Request - State: closed - Opened by whynowy 10 months ago

#1663 - Refactor Source Implementations to Avoid Implementing Forwarder Interface

Issue - State: closed - Opened by yhl25 10 months ago
Labels: area/source

#1662 - chore: Refactor Sinks to Avoid Implementing Forwarder Interface

Pull Request - State: closed - Opened by yhl25 10 months ago

#1661 - chore: do not create init-secrets when auth is disabled

Pull Request - State: closed - Opened by whynowy 10 months ago

#1660 - DLQ for Sink

Issue - State: closed - Opened by vigith 10 months ago - 2 comments
Labels: enhancement, area/sink

#1659 - chore: remove pods/exec from UX server RBAC

Pull Request - State: closed - Opened by whynowy 10 months ago

#1658 - Add ability for examples in SDKs to be built without needing to clone enitre repo

Issue - State: open - Opened by ayildirim21 10 months ago - 2 comments
Labels: enhancement, area/sdk

#1657 - feat: expose controller leader election duration and renew opts

Pull Request - State: closed - Opened by whynowy 10 months ago

#1656 - chore: info level logging for dropped messages

Pull Request - State: closed - Opened by yhl25 10 months ago - 1 comment

#1655 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] 10 months ago

#1654 - feat: add a RetryInterval setting

Pull Request - State: open - Opened by QuentinFAIDIDE 10 months ago - 1 comment

#1653 - fix: add headers to custom sinkrequest

Pull Request - State: closed - Opened by nagarajatantry 10 months ago

#1652 - Encountered error in sinkFn - CANCELLED: client cancelled

Issue - State: open - Opened by nagarajatantry 10 months ago - 2 comments
Labels: bug, opex

#1651 - fix: pass headers to transfomer

Pull Request - State: closed - Opened by yhl25 10 months ago

#1650 - doc: session doc

Pull Request - State: closed - Opened by vigith 10 months ago

#1649 - fix: avoid publishing watermarks for duplicate messages.

Pull Request - State: closed - Opened by yhl25 10 months ago

#1648 - chore: revert examples + add session

Pull Request - State: closed - Opened by vigith 10 months ago

#1647 - fix: flaky TestDropOnFull

Pull Request - State: closed - Opened by yhl25 10 months ago

#1646 - Flaky jetstream-e2e TestDropOnFull

Issue - State: closed - Opened by yhl25 10 months ago
Labels: bug

#1644 - chore: surface SDK compatibility issues through logs

Pull Request - State: closed - Opened by ayildirim21 10 months ago - 4 comments

#1643 - chore: update examples

Pull Request - State: closed - Opened by yhl25 10 months ago - 2 comments

#1642 - chore: set image pull policies to always

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#1642 - chore: set image pull policies to always

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#1641 - Avoid publishing watermark for duplicate messages

Issue - State: open - Opened by yhl25 10 months ago
Labels: bug, area/watermark

#1641 - Avoid publishing watermark for duplicate messages

Issue - State: closed - Opened by yhl25 10 months ago
Labels: bug, area/watermark

#1640 - fix: readonly view

Pull Request - State: closed - Opened by veds-g 11 months ago - 2 comments

#1639 - fix: Dedup not working for multi-partitioned edge

Pull Request - State: closed - Opened by yhl25 11 months ago

#1638 - Easy end-to-end testing framework for pipeline authors that can be integrate to their CI

Issue - State: open - Opened by vigith 11 months ago - 1 comment
Labels: enhancement, testing

#1637 - Offset model does not consider kafka topic name potentially causing wrong dedupe with multi source

Issue - State: closed - Opened by nagarajatantry 11 months ago - 5 comments
Labels: bug, area/source

#1636 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] 11 months ago

#1635 - Dedup not working as expected when using multi-partitioned edges

Issue - State: closed - Opened by yhl25 11 months ago
Labels: bug, area/isb-jetstream, area/forward

#1635 - Dedup not working as expected when using multi-partitioned edges

Issue - State: closed - Opened by yhl25 11 months ago
Labels: bug, area/isb-jetstream, area/forward

#1634 - Track read metrics at partition level for user defined source

Issue - State: closed - Opened by yhl25 11 months ago
Labels: enhancement, opex, area/source, area/udf

#1633 - Seeing duplicate messages in user defined source

Issue - State: open - Opened by yhl25 11 months ago - 2 comments
Labels: bug, area/source, area/udf

#1633 - Seeing duplicate messages in user defined source

Issue - State: open - Opened by yhl25 11 months ago
Labels: bug, area/source, area/udf

#1632 - Enable cors nuaflow api

Pull Request - State: closed - Opened by a49ibrahim 11 months ago

#1632 - Enable cors nuaflow api

Pull Request - State: closed - Opened by a49ibrahim 11 months ago

#1631 - Enable cors for numaflow api

Pull Request - State: closed - Opened by a49ibrahim 11 months ago

#1630 - chore: USERS in alphabetical order

Pull Request - State: closed - Opened by whynowy 11 months ago

#1629 - Do not create init admin secret when auth is disabled.

Issue - State: closed - Opened by whynowy 11 months ago - 1 comment
Labels: enhancement, area/ui

#1628 - feat: read only view for UI

Pull Request - State: closed - Opened by veds-g 11 months ago - 4 comments

#1627 - enable cors for general purpose

Pull Request - State: closed - Opened by a49ibrahim 11 months ago

#1626 - Enable Cors branch fix test

Pull Request - State: closed - Opened by a49ibrahim 11 months ago

#1625 - Easy way to test Source, SourceTransformer, Map, and Sink in Java

Issue - State: closed - Opened by vigith 11 months ago - 1 comment
Labels: enhancement, testing, area/sdk

#1625 - Easy way to test Source, SourceTransformer, Map, and Sink in Java

Issue - State: open - Opened by vigith 11 months ago
Labels: enhancement, testing, area/sdk

#1624 - fix: support DiscardNew policy for Jetstream streams

Pull Request - State: closed - Opened by QuentinFAIDIDE 11 months ago - 8 comments

GitHub / numaproj/numaflow issues and pull requests