diff options
| author | qrort <qrort@yandex-team.com> | 2023-09-20 10:36:08 +0300 |
|---|---|---|
| committer | qrort <qrort@yandex-team.com> | 2023-09-20 11:02:33 +0300 |
| commit | 8ed995cdfb22a3dfa790b0a6ae7750d9dc85db7b (patch) | |
| tree | 7fe7ec8281e107feff1c212e54f60efa961ac7a4 | |
| parent | 12dab647f0e4a604fd6e3421866361b3fd5f5d8d (diff) | |
| download | ydb-8ed995cdfb22a3dfa790b0a6ae7750d9dc85db7b.tar.gz | |
KIKIMR-19337: stream data fix, env variable for local_ydb pgwire port
| -rw-r--r-- | ydb/core/local_pgwire/pgwire_kqp_proxy.cpp | 2 | ||||
| -rw-r--r-- | ydb/tests/library/harness/kikimr_config.py | 4 |
2 files changed, 5 insertions, 1 deletions
diff --git a/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp b/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp index 08a3103dc8..7447d79cbd 100644 --- a/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp +++ b/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp @@ -238,7 +238,7 @@ public: BLOG_D(this->SelfId() << " Send stream data ack to " << ev->Sender); auto resp = MakeHolder<NKqp::TEvKqpExecuter::TEvStreamDataAck>(); resp->Record.SetSeqNo(ev->Get()->Record.GetSeqNo()); - resp->Record.SetFreeSpace(std::numeric_limits<ui64>::max()); + resp->Record.SetFreeSpace(std::numeric_limits<i64>::max()); Send(ev->Sender, resp.Release()); } diff --git a/ydb/tests/library/harness/kikimr_config.py b/ydb/tests/library/harness/kikimr_config.py index 00a6c9eb01..c2de76a6dd 100644 --- a/ydb/tests/library/harness/kikimr_config.py +++ b/ydb/tests/library/harness/kikimr_config.py @@ -234,6 +234,10 @@ class KikimrConfigGenerator(object): if os.getenv('YDB_TABLE_ENABLE_PREPARED_DDL', 'false').lower() == 'true': self.yaml_config["table_service_config"]["enable_prepared_ddl"] = True + if os.getenv('PGWIRE_LISTENING_PORT', ''): + self.yaml_config["local_pg_wire_config"] = {} + self.yaml_config["local_pg_wire_config"]["listening_port"] = os.getenv('PGWIRE_LISTENING_PORT') + if disable_iterator_reads: self.yaml_config["table_service_config"]["enable_kqp_scan_query_source_read"] = False self.yaml_config["table_service_config"]["enable_kqp_data_query_source_read"] = False |