We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f6b39d7 commit f067069Copy full SHA for f067069
1 file changed
datafusion/physical-plan/src/repartition/mod.rs
@@ -1645,7 +1645,7 @@ impl RepartitionExec {
1645
for batch in output_channel.coalesce(batch)? {
1646
if output_channel.send(batch).await.is_err() {
1647
// If the other end has hung up, it was an early shutdown (e.g. LIMIT)
1648
- // Only shrink memory if it was a memory batch
+ // so ignore this channel from now on.
1649
output_channels.remove(&partition);
1650
break;
1651
}
0 commit comments