diff options
author | aakulaga <aakulaga@ydb.tech> | 2023-07-01 10:21:17 +0300 |
---|---|---|
committer | aakulaga <aakulaga@ydb.tech> | 2023-07-01 10:21:17 +0300 |
commit | 936178f666280af0bb960fde32c2fbaf0e86d330 (patch) | |
tree | 16e446ed427ce9360fff5543825a68421a53862e | |
parent | a6623794d2fcbb37f4ae0e6d2435130e7187cc2e (diff) | |
download | ydb-936178f666280af0bb960fde32c2fbaf0e86d330.tar.gz |
Fix AnyJoin second initialization
Fix AnyJoin second initialization
-rw-r--r-- | ydb/library/yql/minikql/comp_nodes/mkql_grace_join_imp.cpp | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_grace_join_imp.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_grace_join_imp.cpp index 6a3844e3552..aa9e6253b3a 100644 --- a/ydb/library/yql/minikql/comp_nodes/mkql_grace_join_imp.cpp +++ b/ydb/library/yql/minikql/comp_nodes/mkql_grace_join_imp.cpp @@ -331,9 +331,6 @@ void TTable::Join( TTable & t1, TTable & t2, EJoinKind joinKind, bool hasMoreLef TTableBucket * bucket1 = &JoinTable1->TableBuckets[bucket]; TTableBucket * bucket2 = &JoinTable2->TableBuckets[bucket]; - KeysHashTable& kh1 = bucket1->AnyHashTable; - KeysHashTable& kh2 = bucket2->AnyHashTable; - ui64 headerSize1 = JoinTable1->HeaderSize; ui64 headerSize2 = JoinTable2->HeaderSize; ui64 nullsSize1 = JoinTable1->NullsBitmapSize_; @@ -367,13 +364,6 @@ void TTable::Join( TTable & t1, TTable & t2, EJoinKind joinKind, bool hasMoreLef joinSlots.resize(nSlots*slotSize, 0); slotToIdx.resize(nSlots, 0); - kh1.NSlots = nSlots; - kh1.SlotSize = slotSize; - - - kh2.NSlots = nSlots; - kh2.SlotSize = slotSize; - ui32 tuple2Idx = 0; auto it2 = bucket2->KeyIntVals.begin(); while (it2 != bucket2->KeyIntVals.end() ) { |