Exception in TKqpStreamLookupWorker

[Hor911]

<main>: Warning: Execution, code: 1060
    <main>:9:26: Warning: Cost Based Optimizer could not be applied to this query: couldn't load statistics, code: 8001
<main>: Error: ydb/core/kqp/runtime/kqp_stream_lookup_worker.cpp:616  BuildRequests(): requirement rowIt != PendingLeftRowsByKey.end() failed
<main>: Error: Query invalidated on scheme/internal error during Data execution, code: 2019

How to reproduce

cd ~/ydb/ydb/tests/functional/compatibility
~/ydb/ya make -r -tA -F test_stress.py::TestStress::test_tpch1[current-row]

1. Change test_stress.py to run Q12 only

hor911@mr-nvme-testing-004:~/ydb/ydb/tests/functional/compatibility$ git diff test_stress.py
diff --git a/ydb/tests/functional/compatibility/test_stress.py b/ydb/tests/functional/compatibility/test_stress.py
index a6e6ca25000..08b5345caff 100644
--- a/ydb/tests/functional/compatibility/test_stress.py
+++ b/ydb/tests/functional/compatibility/test_stress.py
@@ -255,10 +257,14 @@ class TestStress(object):
             "tpch",
             "run",
             "--scale=1",
-            "--exclude",
+            "--include",
             # not working for row tables
-            "17",
+            "12",
             "--check-canonical",
+            "--iterations",
+            "10",
         ]

         yatest.common.execute(init_command, wait=True, stdout=self.output_f, stderr=self.output_f)

Ignore possible Table '/Root/tpch/lineitem' retry limit exceeded error in 1st run

2. Change test_stress.py to run Q10 only with different feature falg set

hor911@mr-nvme-testing-004:~/ydb/ydb/tests/functional/compatibility$ git diff test_stress.py
diff --git a/ydb/tests/functional/compatibility/test_stress.py b/ydb/tests/functional/compatibility/test_stress.py
index a6e6ca25000..08b5345caff 100644
--- a/ydb/tests/functional/compatibility/test_stress.py
+++ b/ydb/tests/functional/compatibility/test_stress.py
@@ -32,6 +32,8 @@ class TestStress(object):
             # uncomment for 64 datetime in tpc-h/tpc-ds
             # extra_feature_flags={"enable_table_datetime64": True},
         )
+        self.config.yaml_config["table_service_config"]["enable_kqp_data_query_stream_lookup"] = True
+        self.config.yaml_config["table_service_config"]["enable_kqp_data_query_stream_idx_lookup_join"] = True

         self.cluster = KiKiMR(self.config)
         self.cluster.start()
@@ -255,10 +257,14 @@ class TestStress(object):
             "tpch",
             "run",
             "--scale=1",
-            "--exclude",
+            "--include",
             # not working for row tables
-            "17",
+            "10",
             "--check-canonical",
+            "--iterations",
+            "10",
         ]

         yatest.common.execute(init_command, wait=True, stdout=self.output_f, stderr=self.output_f)