Skip to content

Commit 09007d4

Browse files
committed
fix cancelation of pipeline
1 parent 4f29f16 commit 09007d4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Interpreters/AsynchronousInsertQueue.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -980,8 +980,8 @@ try
980980

981981
if (chunk.getNumRows() == 0)
982982
{
983+
pipeline.cancel(); // this just cancels the processors
983984
finish_entries(std::move(pipeline), /*num_rows=*/ 0, /*num_bytes=*/ 0);
984-
// pipeline.cancel();
985985
return;
986986
}
987987

0 commit comments

Comments
 (0)