Data

Tools

Indexes

Applications

Experiments

Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / numaproj/numaflow-go issues and pull requests

#193 - chore: close windows when the client sends close operation

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

#191 - chore: update grpc-go version to latest

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

#190 - chore: update redis sink example to check for message order

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

#189 - feat: utility function to persist critical error

Pull Request - State: closed - Opened by adarsh0728 4 months ago - 1 comment

#188 - fix: redis sink example to not create client for every sink invocation

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

#187 - fix: graceful shutdown in accumulator

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

#186 - fix: stream sorter example, return when the channel is closed

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

#185 - feat: Accumulator

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

#184 - Accumulator in Go SDK

Issue - State: closed - Opened by vigith 5 months ago

#183 - chore: ud-container env variable for formalising the errors

Pull Request - State: closed - Opened by adarsh0728 5 months ago

#182 - chore: Publish sink-serve and redis-store images

Pull Request - State: closed - Opened by BulkBeing 5 months ago

#181 - feat: Redis user-defined store implementation

Pull Request - State: closed - Opened by BulkBeing 5 months ago

#180 - chore: add serve response type

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

#179 - chore: add serving store example, change interface and types

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

#178 - feat: Sink serve API

Pull Request - State: closed - Opened by BulkBeing 5 months ago

#177 - chore: update the latest toolchains

Pull Request - State: closed - Opened by vigith 5 months ago - 1 comment

#175 - fix: server stuck during shutdown in multi-partitioned pipeline

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

#174 - Add common prefix and formalize error messages

Issue - State: closed - Opened by adarsh0728 6 months ago
Labels: debuggability

#173 - chore: update panic error handling in containers

Pull Request - State: closed - Opened by adarsh0728 6 months ago - 2 comments

#172 - feat: new Mapper example which serves as a slow container for testing purposes

Pull Request - State: closed - Opened by juliev0 7 months ago - 2 comments

#171 - chore: Map Stream to Support Concurrent Requests

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

#170 - chore: update go mod for examples

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

#169 - chore: update compatible numaflow version

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

#168 - chore: fix sourcer to read all responses

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

#167 - chore: fix simple-source

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

#166 - chore: fix side-input

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

#165 - chore: shutdown when we see non retryable udf errors

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

#164 - chore: update side input example

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

#163 - chore: Batch ack requests and sink responses for better performance

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

#160 - chore: code review

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

#159 - chore: code review

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

#158 - feat: Using gRPC Bidirectional Streaming for Map

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

#157 - chore: update examples

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

#156 - fix: remove unwanted go routines

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

#155 - chore: update examples

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

#154 - feat: container-type level version compatibility check

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

#152 - docs: add instructions on how to update MinimumNumaflowVersion

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

#151 - feat: Bidirectional Streaming for UDSink

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

#150 - chore: update sideinput example

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

#149 - chore: update examples

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

#148 - chore: update examples to latest sdk version

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

#147 - feat: Use bidirectional streaming for Source Transformer

Pull Request - State: closed - Opened by BulkBeing 11 months ago - 1 comment

#146 - feat: use gRPC bidirectional streaming for udsource

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

#145 - chore: log panics inside udf

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

#144 - chore: set CGO_ENABLED=0 for build command

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

#143 - chore: update examples

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

#142 - fix: multi-architecture builds

Pull Request - State: closed - Opened by ayildirim21 12 months ago - 2 comments

#141 - chore: update compatible numaflow version

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

#140 - ARM64 image of simple-source contains amd64 binary

Issue - State: closed - Opened by BulkBeing 12 months ago - 4 comments

#139 - chore: directly use hash key to check messages

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

#138 - chore: handle panic and do graceful shutdown of the server

Pull Request - State: closed - Opened by yhl25 about 1 year ago - 1 comment

#137 - feat: use same server info for all map modes

Pull Request - State: closed - Opened by kohlisid about 1 year ago - 4 comments

#136 - Add tests for panics and context cancellation scenarios

Issue - State: open - Opened by kohlisid about 1 year ago

#135 - chore: stop hard coding quay.io image registry (#134)

Pull Request - State: closed - Opened by kohlisid about 1 year ago

#134 - chore: stop hard coding quay.io image registry

Pull Request - State: closed - Opened by ayildirim21 about 1 year ago - 1 comment

#133 - feat: implement batch map

Pull Request - State: closed - Opened by kohlisid about 1 year ago

#132 - feat: implement batch map

Pull Request - State: closed - Opened by kohlisid about 1 year ago - 1 comment

#131 - chore: remove unnecessary flag

Pull Request - State: closed - Opened by ayildirim21 about 1 year ago

#130 - Set up codecov

Issue - State: open - Opened by whynowy about 1 year ago

#129 - feat: protobuf definition for stream mapper with stream input

Pull Request - State: closed - Opened by magelisk over 1 year ago

#128 - chore: UDS based multiproc

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#127 - chore: fix reduce-sideinput dockerfile

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#126 - feat: Initial GRPC/Protobuf Implementation for batched mapping

Pull Request - State: closed - Opened by magelisk over 1 year ago

#125 - chore: add sideinput and redis-e2e-test sink examples

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#124 - chore: update numaflow-go to v0.7.0-rc2

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago - 1 comment

#123 - chore: update log-sink example Makefile

Pull Request - State: closed - Opened by KeranYang over 1 year ago

#122 - chore: fallback log sink example

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#121 - chore: update MinimumNumaflowVersion

Pull Request - State: closed - Opened by KeranYang over 1 year ago

#120 - feat: Fallback Sink

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#119 - chore: make release doc more readable

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#118 - chore: update release doc

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#117 - chore: add release documentation

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#116 - chore: update server info field name

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#115 - chore: add minimum client version to server info struct

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago - 1 comment

#114 - chore: add sessionreducer sum example to CI

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#113 - add unit tests for EOF reduce streamer and session

Issue - State: open - Opened by KeranYang over 1 year ago

#112 - chore: refactor developer guide

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#111 - chore: session sum example

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#110 - Missing session-sum source code

Issue - State: closed - Opened by KeranYang over 1 year ago

#109 - chore: remove duplicate functionality

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#108 - feat: support headers for message

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#107 - chore: move update script into hack directory

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#106 - chore: update development.md

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#105 - Update version

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#104 - fix: CI workflow

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#103 - Test ci

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#102 - feat: implement update script and build/push workflow

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago - 4 comments

#101 - auto-detect old dependencies in our examples

Issue - State: open - Opened by KeranYang over 1 year ago

#100 - chore: unit test merge operation as a blocking call

Pull Request - State: closed - Opened by KeranYang over 1 year ago

#99 - chore: update examples

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago - 1 comment

#98 - chore: create new server info file paths for all services

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#97 - chore: write server info for sideinput sdk

Pull Request - State: closed - Opened by ayildirim21 over 1 year ago

#96 - refactor the reduce proto

Issue - State: open - Opened by KeranYang over 1 year ago

#95 - fix: memory leak inside session reducer

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#94 - chore: update readme

Pull Request - State: closed - Opened by yhl25 over 1 year ago