diff options
| author | yumkam <yumkam7@ydb.tech> | 2024-08-14 19:30:58 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-14 19:30:58 +0300 |
| commit | 77fc854cd2a1d4b51ebff865c356a02cc19e488c (patch) | |
| tree | a929b798b0b1b8ff7bbc3a97b1ec8b92e73318dd | |
| parent | c70d3ebbec403ebd3f095f2a931d8a061589094c (diff) | |
| download | ydb-77fc854cd2a1d4b51ebff865c356a02cc19e488c.tar.gz | |
dq_input_transform_lookup: fix maxKeysInRequest logic (#7592)
| -rw-r--r-- | ydb/library/yql/dq/actors/input_transforms/dq_input_transform_lookup.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
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 index 38576688ca1..4633cbdd44e 100644 --- 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 @@ -168,9 +168,8 @@ private: //IDqComputeActorAsyncInput 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) { |