mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-20 05:05:38 +00:00
Merge pull request #65935 from ClickHouse/backport/24.6/65771
Backport #65771 to 24.6: PostgreSQL source support cancel query
This commit is contained in:
commit
6c7e71a98b
@ -191,6 +191,12 @@ PostgreSQLSource<T>::~PostgreSQLSource()
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
if (stream)
|
||||||
|
{
|
||||||
|
tx->conn().cancel_query();
|
||||||
|
stream->close();
|
||||||
|
}
|
||||||
|
|
||||||
stream.reset();
|
stream.reset();
|
||||||
tx.reset();
|
tx.reset();
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user