streamlookup: fix monitoring/counters (backport #11071) (#11126)

yumkam · web-flow · commit 01567d5bb197 · 2024-10-31T08:30:32.000+03:00
diff --git a/ydb/library/yql/dq/actors/input_transforms/dq_input_transform_lookup.cpp b/ydb/library/yql/dq/actors/input_transforms/dq_input_transform_lookup.cpp
@@ -256,7 +256,7 @@ class TInputTransformStreamLookupBase
                 }
                 ++row;
             }
-            if (Batches && (!KeysForLookup->empty() || !ReadyQueue.RowCount())) {
+            if (Batches && (!KeysForLookup->empty() || ReadyQueue.RowCount())) {
                 Batches->Inc();
                 LruHits->Add(ReadyQueue.RowCount());
                 LruMiss->Add(AwaitingQueue.size());

Original file line number	Diff line number	Diff line change
`@@ -256,7 +256,7 @@ class TInputTransformStreamLookupBase`
`256`	`256`	`}`
`257`	`257`	`++row;`
`258`	`258`	`}`
`259`		`- if (Batches && (!KeysForLookup->empty() \|\| !ReadyQueue.RowCount())) {`
	`259`	`+ if (Batches && (!KeysForLookup->empty() \|\| ReadyQueue.RowCount())) {`
`260`	`260`	`Batches->Inc();`
`261`	`261`	`LruHits->Add(ReadyQueue.RowCount());`
`262`	`262`	`LruMiss->Add(AwaitingQueue.size());`