fixes(executor): support abort for pipeline executor stream

[zhang2014]

I hereby agree to the terms of the CLA available at: https://databend.rs/dev/policies/cla/

Summary

fixes(executor): support abort for pipeline executor stream

Changelog

• Bug Fix

Related Issues

Fixes #4871

[vercel]

The latest updates on your projects. Learn more about Vercel for Git ↗︎

1 Ignored Deployment

Name	Status	Preview	Updated
databend	⬜️ Ignored (Inspect)		Jun 6, 2022 at 0:54AM (UTC)

[mergify]

Thanks for the contribution!
I have applied any labels matching special text in your PR Changelog.

Please review the labels and make any necessary changes.

[zhang2014]

Maybe we need to add a test, but I don't know how to do it.

[TCeason]

Maybe we need to add a test, but I don't know how to do it.

tests/suites/1_stateful/02_query/02_0000_kill_query.py

replace SQL SELECT SLEEP(2.9) to which you want to test.

[BohuTANG]

How about the insert query?

[zhang2014]

How about the insert query?

insert query is different select query. In insert query, we always return stream when all data is wrote. abort insert query require some refactoring, which is in my todo list.

issue: #4646

[TCeason]

LGTM and I can modify the test for this pr.