tcp_boundary: drop source correctly#11987
Conversation
Instead of waiting to schedule ok and err streams to drop the source, only require a single of the streams to be terminate to terminate both. This prevents a situation where the ok stream is terminated, but the err stream will not pick up the termination because it won't be scheduled anymore. Signed-off-by: Moritz Hoffmann <mh@materialize.com>
|
This is an alternative to #11945. |
guswynn
left a comment
There was a problem hiding this comment.
I am convinced now that #11945 is definitely a backwards approach, but this technique concerns me for 2 reasons:
- What is different about the
okanderrstream where, as the source is dying? Is theokstream always going to get a push? if it is also not getting any data (just like theerr) stream, could neither of these be called and we have the same bug? - My other comment inline; I don't understand timely well enough to know if this is a concern
|
#12082 should be able to replace this pr |
|
|
1 similar comment
|
|
|
On my list of "pending reviews" but I suspect we just want to close? |
|
@frankmcsherry yeah, this should be relevant anymore! |
Instead of waiting to schedule ok and err streams to drop the source, only
require a single of the streams to be terminate to terminate both. This
prevents a situation where the ok stream is terminated, but the err stream
will not pick up the termination because it won't be scheduled anymore.
Signed-off-by: Moritz Hoffmann mh@materialize.com
Motivation
Testing
Release notes
This PR includes the following user-facing behavior changes: