v0.11.0

What's Changed

• fix: client cancellation should not trigger grpc shutdown by @yhl25 in #204
• fix: client cancellation shouldn't trigger shutdown for source by @adarsh0728 in #205
• chore: restructure examples directory and update them to use v0.10.1 by @adarsh0728 in #206
• feat: nack support for udsource by @yhl25 in #210
• chore: update side input example by @yhl25 in #212
• feat: metadata implementation for source, map and sink by @adarsh0728 in #208
• fix: shutdown was hanging due to a blocking write on channel by @kohlisid in #213

Full Changelog: v0.10.1...v0.11.0

v0.10.1

What's Changed

• chore: update accumulator proto by @yhl25 in #200
• fix: update accumulator example by @cosmic-chichu in #201
• feat: error handling for reduce by @adarsh0728 in #203

New Contributors

• @cosmic-chichu made their first contribution in #201

Full Changelog: v0.10.0...v0.10.1

v0.10.0

What's Changed

• chore: update go mod for examples by @KeranYang in #170
• chore: Map Stream to Support Concurrent Requests by @yhl25 in #171
• feat: new Mapper example which serves as a slow container for testing purposes by @juliev0 in #172
• chore: update panic error handling in containers by @adarsh0728 in #173
• fix: server stuck during shutdown in multi-partitioned pipeline by @yhl25 in #175
• feat: Custom Serve Store for integration with any user-defined store by @vigith in #176
• chore: Publish sink-serve and redis-store images by @BulkBeing in #182
• chore: ud-container env variable for formalising the errors by @adarsh0728 in #183
• feat: Accumulator by @yhl25 in #185
• fix: stream sorter example, return when the channel is closed by @yhl25 in #186
• fix: graceful shutdown in accumulator by @yhl25 in #187
• fix: redis sink example to not create client for every sink invocation by @yhl25 in #188
• chore: update redis sink example to check for message order by @yhl25 in #190
• feat: utility function to persist critical error by @adarsh0728 in #189
• chore: update grpc-go version to latest by @yhl25 in #191
• chore: add examples for e2e rust runtime by @adarsh0728 in #194
• fix: crypto pkg critical security vulnerability in examples by @adarsh0728 in #195
• chore: handle panics in reduce by @adarsh0728 in #196

New Contributors

• @adarsh0728 made their first contribution in #173

Full Changelog: v0.9.0...v0.10.0

v0.9.0

What's Changed

• chore: update examples to latest sdk version by @yhl25 in #148
• feat: use gRPC bidirectional streaming for udsource by @yhl25 in #146
• chore: update examples by @yhl25 in #149
• chore: update sideinput example by @yhl25 in #150
• docs: add instructions on how to update MinimumNumaflowVersion by @KeranYang in #152
• feat: container-type level version compatibility check by @KeranYang in #154
• feat: Bidirectional Streaming for UDSink by @yhl25 in #151
• chore: update examples by @yhl25 in #155
• fix: remove unwanted go routines by @vigith in #156
• feat: Use bidirectional streaming for Source Transformer by @BulkBeing in #147
• chore: update examples by @yhl25 in #157
• feat: Using gRPC Bidirectional Streaming for Map by @yhl25 in #158
• chore: code review by @vigith in #160
• feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol by @yhl25 in #161
• feat: Unify Map Stream and Unary Map Operations Using a Shared gRPC Protocol by @yhl25 in #162
• chore: Batch ack requests and sink responses for better performance by @yhl25 in #163
• chore: update side input example by @yhl25 in #164
• chore: shutdown when we see non retryable udf errors by @yhl25 in #165
• chore: fix side-input by @vigith in #166
• chore: fix simple-source by @vigith in #167
• chore: fix sourcer to read all responses by @yhl25 in #168
• chore: update compatible numaflow version by @KeranYang in #169

New Contributors

• @BulkBeing made their first contribution in #147

Full Changelog: v0.8.1...v0.9.0

v0.8.1

What's Changed

• chore: update examples by @KeranYang in #143
• fix: multi-architecture builds by @ayildirim21 in #142
• chore: set CGO_ENABLED=0 for build command by @ayildirim21 in #144
• chore: log panics inside udf by @yhl25 in #145

Full Changelog: v0.8.0...v0.8.1

v0.8.0

What's Changed

• chore: remove unnecessary flag by @ayildirim21 in #131
• chore: stop hard coding quay.io image registry by @ayildirim21 in #134
• feat: implement batch map by @kohlisid in #133
• feat: use same server info for all map modes by @kohlisid in #137
• chore: handle panic and do graceful shutdown of the server by @yhl25 in #138
• chore: directly use hash key to check messages by @KeranYang in #139
• chore: update compatible numaflow version by @KeranYang in #141

Full Changelog: v0.7.0...v0.8.0

v0.7.0

What's Changed

• chore: update examples with latest sdk version by @yhl25 in #93
• feat: Session Window and Reduce Streaming by @yhl25 in #87
• chore: update readme by @yhl25 in #94
• fix: memory leak inside session reducer by @yhl25 in #95
• chore: write server info for sideinput sdk by @ayildirim21 in #97
• chore: create new server info file paths for all services by @ayildirim21 in #98
• chore: unit test merge operation as a blocking call by @KeranYang in #100
• chore: update examples by @ayildirim21 in #99
• feat: implement update script and build/push workflow by @ayildirim21 in #102
• fix: CI workflow by @ayildirim21 in #104
• chore: update development.md by @ayildirim21 in #106
• chore: move update script into hack directory by @ayildirim21 in #107
• feat: support headers for message by @yhl25 in #108
• chore: remove duplicate functionality by @ayildirim21 in #109
• chore: refactor developer guide by @ayildirim21 in #112
• chore: session sum example by @yhl25 in #111
• chore: add sessionreducer sum example to CI by @ayildirim21 in #114
• chore: add minimum client version to server info struct by @ayildirim21 in #115
• chore: update server info field name by @ayildirim21 in #116
• chore: add release documentation by @ayildirim21 in #117
• chore: update release doc by @ayildirim21 in #118
• chore: make release doc more readable by @ayildirim21 in #119
• feat: Fallback Sink by @yhl25 in #120
• chore: update MinimumNumaflowVersion by @KeranYang in #121
• chore: fallback log sink example by @yhl25 in #122
• chore: update log-sink example Makefile by @KeranYang in #123
• chore: update numaflow-go to v0.7.0-rc2 by @ayildirim21 in #124
• chore: add sideinput and redis-e2e-test sink examples by @ayildirim21 in #125
• chore: fix reduce-sideinput dockerfile by @ayildirim21 in #127

Full Changelog: v0.6.0...v0.7.0

v0.7.0-rc2

What's Changed

• chore: add minimum client version to server info struct by @ayildirim21 in #115
• chore: update server info field name by @ayildirim21 in #116
• chore: add release documentation by @ayildirim21 in #117
• chore: update release doc by @ayildirim21 in #118
• chore: make release doc more readable by @ayildirim21 in #119
• feat: Fallback Sink by @yhl25 in #120
• chore: update MinimumNumaflowVersion by @KeranYang in #121

Full Changelog: v0.7.0-rc1...v0.7.0-rc2

v0.7.0-rc1

What's Changed

• chore: update examples with latest sdk version by @yhl25 in #93
• feat: Session Window and Reduce Streaming by @yhl25 in #87
• chore: update readme by @yhl25 in #94
• fix: memory leak inside session reducer by @yhl25 in #95
• chore: write server info for sideinput sdk by @ayildirim21 in #97
• chore: create new server info file paths for all services by @ayildirim21 in #98
• chore: unit test merge operation as a blocking call by @KeranYang in #100
• chore: update examples by @ayildirim21 in #99
• feat: implement update script and build/push workflow by @ayildirim21 in #102
• fix: CI workflow by @ayildirim21 in #104
• chore: update development.md by @ayildirim21 in #106
• chore: move update script into hack directory by @ayildirim21 in #107
• feat: support headers for message by @yhl25 in #108
• chore: remove duplicate functionality by @ayildirim21 in #109
• chore: refactor developer guide by @ayildirim21 in #112
• chore: session sum example by @yhl25 in #111
• chore: add sessionreducer sum example to CI by @ayildirim21 in #114

Full Changelog: v0.6.0...v0.7.0-rc1

v0.6.0

What's Changed

• fix: require specifying event time when dropping a message using source transformer by @KeranYang in #90
• chore: adding partitions for user defined source by @yhl25 in #91
• chore: reduce refactor by @yhl25 in #92

Full Changelog: v0.5.2...v0.6.0