Commit 71f7b78
fix panic when Unfold sink return an error (#2686)
- fix issue #2600. When an Unfold sink return an error
it is left in an invalid state. Calling after that flush/close
cause the sink to panic due to re-calling a future already completed.
This patch aims to leave the sink in a valid state and allow calling
flush/close without causing a panic.1 parent eb68070 commit 71f7b78
1 file changed
+4
-1
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
73 | 73 | | |
74 | 74 | | |
75 | 75 | | |
76 | | - | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
77 | 80 | | |
78 | 81 | | |
79 | 82 | | |
| |||
0 commit comments