fix(cluster): try fix broken pipe or connect reset

[zhang2014]

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

Summary

fix(cluster): try fix broken pipe or connect reset

When we use two-way streaming grpc for data exchange, if the client side is closed and the server side reads data immediately. we will get a broken pipe or connect reset error.
In this pr: we use the ClosingClient to notify the server side to close the connection for avoid errors.

fixes #8221
fixes #7986

[vercel]

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

1 Ignored Deployment

Name	Status	Preview	Updated
databend	⬜️ Ignored (Inspect)		Dec 6, 2022 at 7:27AM (UTC)

[zhang2014]

The test is still in progress. before applying this pr, we will get error when run tpch q5(~10 times). after applying this pr, no any error has occurred (~261 times).

260 times

Running 1 stateless tests.

13_0005_q5:                                                             [ OK ]

1 tests passed. 0 tests skipped.
261 times

Running 1 stateless tests.

13_0005_q5:                                                             [ OK ]

1 tests passed. 0 tests skipped.

[zhang2014]

@mergify update

[mergify]

update

❌ Base branch update has failed

refusing to allow a GitHub App to create or update workflow .github/workflows/dev-linux.yml without workflows permission
err-code: FEC32