search

numaproj / numaflow-java

Numaflow Java SDK
Apache License 2.0
22 stars 10 forks source link

chore: send one EOF response only for reduce stream #102

Closed KeranYang closed 6 months ago

KeranYang commented 6 months ago

Reflecting changes from go SDK - https://github.com/numaproj/numaflow-go/pull/111

Tested against numaflow main using TestReduceStreamJava.

yhl25 commented 6 months ago

Can you make the change for the reducer as well?

KeranYang commented 6 months ago

@yhl25 good catch, thanks! Addressed.