Commit 2ea3251
committed
sink: fix old bug determining whether more batches should be produced
The conditional was backwards... canLinger is true if we have lingering
configured.
What this meant: we we starting lingers with 0 duration that would
immediately fire.1 parent 309bff3 commit 2ea3251
1 file changed
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1438 | 1438 | | |
1439 | 1439 | | |
1440 | 1440 | | |
1441 | | - | |
| 1441 | + | |
1442 | 1442 | | |
1443 | 1443 | | |
1444 | 1444 | | |
| |||
0 commit comments