Skip to content

Commit

Permalink
dq_input_transform_lookup: fix maxKeysInRequest logic (ydb-platform#7592
Browse files Browse the repository at this point in the history
)

(cherry picked from commit 77fc854)
  • Loading branch information
yumkam committed Aug 23, 2024
1 parent 434b4dd commit 26df92a
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -168,9 +168,8 @@ class TInputTransformStreamLookupBase
const auto maxKeysInRequest = LookupSource.first->GetMaxSupportedKeysInRequest();
IDqAsyncLookupSource::TUnboxedValueMap keysForLookup{maxKeysInRequest, KeyTypeHelper->GetValueHash(), KeyTypeHelper->GetValueEqual()};
while (
((InputFlowFetchStatus = FetchWideInputValue(inputRowItems)) == NUdf::EFetchStatus::Ok) &&
(keysForLookup.size() < maxKeysInRequest)
) {
(keysForLookup.size() < maxKeysInRequest) &&
((InputFlowFetchStatus = FetchWideInputValue(inputRowItems)) == NUdf::EFetchStatus::Ok)) {
NUdf::TUnboxedValue* keyItems;
NUdf::TUnboxedValue key = HolderFactory.CreateDirectArrayHolder(InputJoinColumns.size(), keyItems);
for (size_t i = 0; i != InputJoinColumns.size(); ++i) {
Expand Down

0 comments on commit 26df92a

Please sign in to comment.