Fix blocking

risingwavelabs · Mar 13, 2023 · c51bf39 · c51bf39
1 parent 2098faf
commit c51bf39
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/batch/src/task/task_execution.rs b/src/batch/src/task/task_execution.rs
@@ -221,6 +221,7 @@ impl TaskOutput {
                 // Error happened
                 Err(e) => {
                     writer.write(Err(tonic::Status::from(&*e))).await?;
+                    break;
                 }
             }
             cnt += 1;