From d494b048bac3cbca89ac88914e14badb4bb0c888 Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 18 Nov 2025 08:11:16 +0000 Subject: [PATCH 1/6] =?UTF-8?q?ivf=20build=20helper=E5=86=85=E5=AD=98?= =?UTF-8?q?=E6=B2=A1=E6=9C=89=E6=B8=85=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: footka <672528926@qq.com> --- src/storage/ddl/ob_ddl_pipeline.cpp | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/storage/ddl/ob_ddl_pipeline.cpp b/src/storage/ddl/ob_ddl_pipeline.cpp index 3d35a5315..e400505aa 100644 --- a/src/storage/ddl/ob_ddl_pipeline.cpp +++ b/src/storage/ddl/ob_ddl_pipeline.cpp @@ -388,8 +388,13 @@ void ObVectorIndexTabletContext::destroy_ivf_build_helper() { int ret = OB_SUCCESS; if (nullptr != helper_) { - if (OB_FAIL(ObPluginVectorIndexUtils::release_vector_index_build_helper(helper_))) { - LOG_ERROR("fail to release vector index adapter", KR(ret)); + ObIAllocator *allocator = helper_->get_allocator(); + if (OB_ISNULL(allocator)) { + ret = OB_ERR_UNEXPECTED; + LOG_WARN("null allocator", K(ret)); + } else { + helper_->~ObIvfBuildHelper(); + allocator->free(helper_); } helper_ = nullptr; } From be322d70da91f886da0ba6961588f2c82c78321c Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 18 Nov 2025 08:41:24 +0000 Subject: [PATCH 2/6] [CP] fix parse sparse vector core Co-authored-by: footka <672528926@qq.com> --- src/share/vector_index/ob_plugin_vector_index_adaptor.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/share/vector_index/ob_plugin_vector_index_adaptor.cpp b/src/share/vector_index/ob_plugin_vector_index_adaptor.cpp index 37e194490..6222b9cdc 100644 --- a/src/share/vector_index/ob_plugin_vector_index_adaptor.cpp +++ b/src/share/vector_index/ob_plugin_vector_index_adaptor.cpp @@ -2380,13 +2380,14 @@ int ObPluginVectorIndexAdaptor::complete_delta_buffer_table_data(ObVectorQueryAd LOG_WARN("failed to alloc sparse byte lens", K(ret), K(count)); } else { char *sparse_curr_pos = sparse_vectors; + int j = 0; // Copy the raw sparse vector data for (int i = 0; OB_SUCC(ret) && i < ctx->get_vec_cnt(); i++) { if (!ctx->vec_data_.vectors_[i].is_null() && !ctx->vec_data_.vectors_[i].get_string().empty()) { ObString vec_str = ctx->vec_data_.vectors_[i].get_string(); - memcpy(sparse_curr_pos, vec_str.ptr(), vec_str.length()); + MEMCPY(sparse_curr_pos, vec_str.ptr(), vec_str.length()); sparse_curr_pos += vec_str.length(); - sparse_byte_lens[i] = vec_str.length(); + sparse_byte_lens[j++] = vec_str.length(); } } From de0b798d42791294baaf109a9b4f243cc78bd59d Mon Sep 17 00:00:00 2001 From: obdev Date: Thu, 20 Nov 2025 10:06:24 +0000 Subject: [PATCH 3/6] Fixing the inability to handle nested requests Co-authored-by: footka <672528926@qq.com> --- deps/oblib/src/rpc/obrpc/ob_rpc_proxy.ipp | 1 + src/observer/omt/ob_multi_level_queue.h | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/deps/oblib/src/rpc/obrpc/ob_rpc_proxy.ipp b/deps/oblib/src/rpc/obrpc/ob_rpc_proxy.ipp index a00831579..b27f9c46c 100644 --- a/deps/oblib/src/rpc/obrpc/ob_rpc_proxy.ipp +++ b/deps/oblib/src/rpc/obrpc/ob_rpc_proxy.ipp @@ -216,6 +216,7 @@ int ObRpcProxy::rpc_call(ObRpcPacketCode pcode, const Input &args, //do nothing } if (dst_ == ObRpcProxy::myaddr_) { + oceanbase::lib::Thread::WaitGuard guard(oceanbase::lib::Thread::WAIT); ret = oceanbase::oblpc::send(*this, pcode, args, result, handle, opts); } else { ret = OB_NOT_SUPPORTED; diff --git a/src/observer/omt/ob_multi_level_queue.h b/src/observer/omt/ob_multi_level_queue.h index 86358f438..691901658 100644 --- a/src/observer/omt/ob_multi_level_queue.h +++ b/src/observer/omt/ob_multi_level_queue.h @@ -20,7 +20,7 @@ #include "lib/queue/ob_priority_queue.h" #include "rpc/ob_request.h" /// TODO remove multi level queue -#define MULTI_LEVEL_QUEUE_SIZE (1) +#define MULTI_LEVEL_QUEUE_SIZE (5) #define MULTI_LEVEL_THRESHOLD (2) #define GROUP_MULTI_LEVEL_THRESHOLD (1) From ae0d170a19dbe5e3a072149600f7a254726a565b Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 25 Nov 2025 02:41:47 +0000 Subject: [PATCH 4/6] sync github docs Co-authored-by: footka <672528926@qq.com> Co-authored-by: hnwyllmm --- docs/developer-guide/assets/favicon.ico | Bin 0 -> 3465 bytes docs/developer-guide/assets/logo.png | Bin 0 -> 6140 bytes docs/developer-guide/en/README.md | 18 +++--- docs/developer-guide/en/build-and-run.md | 8 +-- docs/developer-guide/en/coding-convention.md | 26 ++++---- docs/developer-guide/en/coding-standard.md | 50 +++++++-------- docs/developer-guide/en/container.md | 26 ++++---- docs/developer-guide/en/contributing.md | 2 +- docs/developer-guide/en/debug.md | 18 +++--- docs/developer-guide/en/ide-settings.md | 12 ++-- docs/developer-guide/en/logging.md | 50 +++++++-------- docs/developer-guide/en/memory.md | 20 +++--- docs/developer-guide/en/mysqltest.md | 10 +-- docs/developer-guide/en/toolchain.md | 4 +- docs/developer-guide/en/unittest.md | 8 +-- docs/developer-guide/zh/README.md | 26 ++++---- docs/developer-guide/zh/build-and-run.md | 16 ++--- docs/developer-guide/zh/coding-convention.md | 16 ++--- docs/developer-guide/zh/coding-standard.md | 44 ++++++------- docs/developer-guide/zh/container.md | 24 +++---- docs/developer-guide/zh/contributing.md | 10 +-- docs/developer-guide/zh/debug.md | 32 +++++----- docs/developer-guide/zh/ide-settings.md | 16 ++--- docs/developer-guide/zh/logging.md | 62 +++++++++---------- docs/developer-guide/zh/memory.md | 20 +++--- docs/developer-guide/zh/mysqltest.md | 6 +- docs/developer-guide/zh/toolchain.md | 10 +-- docs/developer-guide/zh/unittest.md | 14 ++--- docs/mkdocs.yml | 1 + 29 files changed, 275 insertions(+), 274 deletions(-) diff --git a/docs/developer-guide/assets/favicon.ico b/docs/developer-guide/assets/favicon.ico index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..9f938fad4b1d3d24fb4fa18feeb277d469e3ccb8 100644 GIT binary patch literal 3465 zcmZu!c{r497k`W;W{_+lF%4quTV)uO-DDY>F!pWiGj>A>uYC*YCA*O2ZIPWqlBF!k zzNOIEm&!Vb`bKYG@AqBTd!Oq(=XamycYfzS_jNsgJaK3PZ6+`e7ytk!T^$W$O1ymR z^mLTxLs##QltATctgQx=_wg=MHjy|pT_=5gK$L>%0a_|nfclt1F@TB(p#6yf07Z4? zH#Vjc`NaVNK#VIu^NV9niN{Na;*{!Nk@`N>KZ^H3zuA}XQ~!gH%WB=FswsiNO9$%< z01&ogrvkEaxF~8^SB#mTnZBN)gC}0n&e78zCmD$MI<5kcfr=D}$NAYo1MwaNU&TOW z*iVKc1s|uSV9=iwKX+xAnLZk-?&*VrUX+xUl!mE*p-?E&$I(gASVQYqIc28|bMf=@ zQk0S+5{Z&TIZ00+XDJy30wE)_++<>%^2 zfFA4G*?ao?DZ^mLjef7c&*|st^iL;(@2{~a14SK|sMkZK+4o_O7q z!}=TY^D}ZEI-?ankDWB`WkjEu6lI!Z6dkCG<6%53lQI7mVUsni!FG-5-uWZD>}}Jd z0gbzE_V)a`Y}aJQhYe7u>^fUlxIE}DG;d_4opoT$R_Idsfbf4eE@2a#4hJhim^6LEc0g zpHLP;vjg}BR(+JfQkkoep^D1}W()RFbe_+1*YOjhp zX(%E1S$CV<_?e?~?EE;Xq@B#xfePY&^1O!yOW906>Pq|LY&zJ(T@)H$z~e_` zUB)Ct*E$_DpCakqOy~b_IX{(_NWabgDy7xJaenyrr8wff*dGs#q-WXTF5Ajs!zWEr zj6Jl2^ky7K9%DqzWE;3PO0MdTm8A=n!r<(zUJ9a-*-T}ezys$u71ePPZcoH9tHouX zPbG}Vg=yt$jdAT9YD94_fSNX*4qU$CuWjpwnJoZy-K-N`;5!F=)0(crA z=;{=>A`>5-RGH9NKYjMiuA6i6?T_LCPEUkJbL}UHF1YCk1JhWC_hBq&8|ko$evG&F zQx%9G2)f$rpb)`40i!M}yl5k9C2REDgaO>Aohu5#&-AFGL<`J$A-!W!gY^JB_j)Pd z1m`P*rulyA@%T0YQLZT_&AfX4bk(YakHRIKKR(pINOai|!ehztRVE3}&b7CbdDC_a zw_;cX!x^=Bo37cg0ofc+8xdk~7GCw%Mq4%3(fQ0_@XN~%;MgkPj7oZIBQ0?qqcb_p zUi9b1l6mzogMEc-f1DgN4YQK=H=q?x3R}l}y(oD;C$*9-3qQK?2a@wv=@?TzZ_<>$ zTVC3DbagKH8;=mQ^ZNy7dw=T;Q6b0MF0wyX%qdJyG0OW-Wa!4pZNt??D- zk>jzgNeT+r=!-BYE`f|;Sp@?8hl1M=x);fnULm%)xr!S)(MH0XOwAgjU2UuU1S5L_6QiBo&Lw56ryl$oy^;TVg1Sbo6;Ab*e6jhNri?;`r6EgHDR7}YlT#WQs!vai>{GhZjjgJA5yB`vf7<;kUr6&QYVZNDOh1{JfOSv3_7-3 zRO40ces^`!__=6(mpQ|v`f z-{7ww@{@t+N9Jy$Lylw_R_my?d#L01_W7p6sOISfIHmu$g5_ zxWs;`u!w{%$zEd%C4>-GNKa@h=^@=QN~v3nllkhv@JWV&*Ybw~ zTX}rRClopk#sNQb$ZbhOZvgMGrQMw^5`mPDB)Vt#>BN7M!}tU zmiM)^wv*VXsUIALgIav!#zRH|4K<~5-K5&^N<#6W;d z9&$-D;gSf}zcfTC)cvtsLc6ckh8IVV5}0e;J?&JdQ$(rdeh$y3M+DuL)7D4+-1yS5w$?!Dc@ z^U|aJdalNN@7erkW;$WzW7X(l`q$pwy{?5p$oyQ&H#JV>4`!$?8aBis&4kiY9~GgP z31+mQ7zZViKwA5bEsXnK*PZG?M5soz3ilnGojlExJJ@x(ohHRIqb3;O?MO62) zNfXW4(=TZcZ#4u8qkZf*}6y6%}@Uz6NrqXpCv}QsmpfJ!XnbXqse88t^)l zfk<6#3<3Pfbl;Zq%UWO#2k(|?Et&YkX9QRrC1{j1ZJiI73LyOt!)`r1sGiIH=7$KM zb~t-~kMr{&vd5$;g{i<49`AjQNH=W=Oc)l7c=y!N?O?pLeEQ0&hS}B9lULzWmKvM^ zEqS{|O^I|@Ym)TPX)i8RbR-P`2Hj*0L!Y9txc@p*I72alqV-+7d^tnjlm5aEu_B({E{AkAe z1m)Z7MiC~3f!#47Jr&n^z>Y(JvpvL04siUq*In;1_I%`QeO~t70iiR6uK8oKEhDaz zv)w0D_ygDbd71{gq2jc1N#H_eHnPA(Nc;2RK}0_GzSpL^|IyG7&)J<2?SL!ZePgRh mOSF3MV)_UFVwO}i-!OIR_$G* zL}--Me*M3{AKtI;IsXs8bDncQ-1|GvJ@>gILSIjl7Qzkz006WPwbTp%03h3c9u@e? z5*G728USGJdZ?yi=$(aMKsg(3`uF_VR6xZuz~acsGNZ_^!}e*TMWkzHD0=l?wnjLv ziq|L3jsqUbjeGJX>dx7&EEeHj_q)G#fXc-gbMNilnQ|qkk7Tk5;Ts*>srBq9uKpY8Qw3Vl-xdd0cF(%gxbPY~u@4y!O{+y1% zyE>U8^xremNR^DJ?-|#Ce-}wG9FwUPZJ)I5Lo6K~GKV^UG&!@BDu<+;lC8XPb@Xl) zftsfnA09)|weoZ;w1>)ekGPa#`C#B8Wi?6ijn0OyQIz)cTgm3s%LjlWA8B}mQ)0$+ zgL`V2WiC%|r#Fmv7-<_$s)AHy2R!m#`C&&@39QELxcJA-Se-4j1nQiHUFBo7yYnrx z$&;dQI!yKGmrPjHu${C*dEKpMaW|a93hJRkoXO51ti=01VvV^){%!EixCGh++*iA$ z@by@0=34D7upl+|IqOhxS~#^OxwynUA&_=w@w2 zdc~h#*+J58%pmbPKneOdolhjgkq0e}5S{~o5V)FLxpc~MvKvozHrcZEL)AR?ePm)W zCLXI4`T9~xvq%1oYH1>17T89yyoe_xmXi zQ6lDOsmTf3x~lP?2i_J06mn@T?i>n~NVCkkAlmT>7*y+@1sg|>t=}Q?H=I+Qt^-y9 zp^DBr)|-t_W>9Oq7x)WQvDFCd9woT=TmNtb@7@JHHg=xbMB$Nf>&QW>YL0Op#m4x* zIw>iJXXf8Z@0$%xK{SE%ao+O-7!V z3)?eY?&`v4~$}PJvjW0W*GYo(KTVH@l$<^}c(J&6Xd$v4_;(tuQ1;qz!(K)~{$w4(O!+PL^E)=Cexd+$qT1sm1v z)?AF~kforB=nF3b7@quEo*042yEe(tJokbV^-Xd2Q2Av&Ni+J>;pkz*+LyrW*w&SXU0+wX)z>O)vSsyRL2 ziGxwcqZ8SP1Xu1+R&rnqB0u_2SQ_Bj*w}X-vGp8nF_rFG zM+LSXHta?RO!f|1a1&>)eY;E1REtmPW9br{p8y(1sPBvMGO>bGHSafWq>hHo1~SfB zcN{N{_q$+ATU*90Zng^}KpeK7;`X7DXk~_YsMz?2wch{E}UJ;`}Q~j#;%<^J(7EJ=*9kBJP%iY>Rd3c9J=Dg{;;!bCT3-*=gAwRTDhL~I+EG20&90@g3 zN#K(P7yT;);>GFvuURL`(_c=Q)mYF+%Y5iK&0jPWhCE8m__5p5vXx3fCxddUA-JW7hn*;nF7F7F~~w%d6QC;+xu=-+*UzD7cH z_WH&meEClb&SjH)ha4bWwRAKej)!C4fgE?w89yCRRaRh?YF}vPu@m2;}^xz&j z1^wywG7_kK`ubfL?o7vZ$DbGN^nP=_N_X?$`CF;{CjQv%n#_}v!(>*oz2S_8tOG%x zQcc730F;QvjomF($2~w9r*?gBwyurW?w4pE9}7K2cWr;IZr0$cr}cSq1(JSYAY+-N zL@&M*2e!0%ZBW_GPJ6_@?q9(fuDJ|$=<$=NBYILrlwtqL7S<(xh@sif>Sl<}onM?) zphO%_)Ri$2hJpc?jW!UdT#kV)(YYcn2@=TzxGjLbhpUibN0kW2R{@hNs7hD1_n)<& z{HQnz`cXl*?;|}Nj2(cpa6blpdam%VDsTNFCzwN@TFW}rQ(42>F{}(?@x+9sQs>#5 zN=!ikO}=&>9H4@b(>dMJ-Mww;)Q&HED2w_rv*mwOQwzN5Pk=I?z_x{o^md{y@~i0e zH-R!zwe9)C4<2$Sxy<5)b}#n3dljb>Br7_q1T7*BdzhN?zbJkYy{`mi5B=;BDAg>p zlrBJOGY`UeARJ98#WdghZ-rM+H++?kDIhTgY}~W@II?Dhp4F$)^joGplMUxKd5AJT$wra@8L8tzP{#ousXcYs}WB*$G?b0ve?qv1=oB_ZgTV6{&64TFX z=^_vwvOX+`8d4*!#p$R|6t;Kgg%~iICt>4KQJFhdysP)( zv$(9(-V%x8h*wVokh^iGKk-RKHX1f`w5!+W zzP<+DP|fPjpGSGj01BM&JI_21M5LOo`-?vYiFuoxF_cp3i*!0VXW?E}ah}YEvl^W)3=Glpu=K)6fZ@gx-s@5* zePK3zVU>ljt4TOVAFTN3kw;UFs_%;QQ=Ek!?5ddtO{$`Ucgj|(#i*7# z75;eoIv4e?dwQSpves(vBi|Vp_0fRapfqD&cTR(a`OYna2)gof9!1ZW z^0YKhFwPyPW`K+&1GBO&eC=F?B!#;`u7dZxJlDHgQGd1%-N+;Jp83EMAue{O8gk*E z#sC{EloF(x*w28b6PRo$0l%wPxZ$r8A*-)IJ5-!~)0h}{UnB)DOjz)a;sU8MO#;vg z<2nk(0w@CR3&NHIF5xJpP43D=QjP+LGfmEt3pD4tOGoBw0hX$YwDh+pf4G_K z3gRCE4G5ON)tOB&FbiW~LvtIHJbn)151dWVU-eWJOut)rM#@GM2(in<|=0%5r z6y;B1`?oS{jBq=DVE=YcL@#?@(R1P&mjtJU|1uS8xX{j z*Wu^mo=Gv*@B}+5Ymm`$JFeljTlID;N0>Sh(eju-&IhoeQtk9>gbwgr*o-m^nc702CJTr7y-X-j}6^TDS#VO z#t#C8zV=DR3H{`qVq+U-&;r!to!rTk5P`VIr5 zLHce`;vYUiBHy+_1=cn-EdTE9_85uOE}j3$hAUa_rB>;}*DeKv>TMAM-I18QsCWP} zg{wYWyWaG1u|+f|=ibj4nI$vHIvd#e?aPf5j^(}#Z=L{Jezm&+G&E*ZQUW5UEuS~> z&+ToRz$gyxsE-_bf63njVqbgiM-Iq^y-0T40{uM20Gfo~Ja~oNTKhslbNG@-U$bf0 zdQADd8m#HX9~kNryU6csmi)LfqnW4Lci6;c{V%Pg)vhxT*P?NPKm^A>{5f%N()L1S zc1QtYS2fON&#hqU)HcX`@xh~fP|D16Dfjy&wDToD|DJX?8k3$ipNmiD`mO^K`HoYs zpB}wG>}FH#)H?XNC)ctaMa zI_5oA4SC(LaV=?atah@a zCI*ui`^y$-hq-sno2fGzU+-SbI(^Jf$mnavMeiz$B*}h41F68;+M{x3t!b^yt_Ffx z&U>^V{_^5n(s!}@Hh7L`E(4_&O8)hs4)v(|^%sigcfd>l?KZA!EZIS_dU@`~ebt*G z#nM5xF}YC48^8d}U_&tl*V29`1O||BZKl-XOR#*$R)^eQ#0G&>$RL7L3Hn+B@oF3L z93j%V!z#{trMmQ?XNp;^;&13YjM}`9iUobnf7$@%35U{Ki8H1q9jS|BvOfIh!!Iuz z``K~ko9d?&B*pEtxY5mobo=PBkP?TR-uaE~S(rR}!GcM~I|juS1Wxl<4CJYb@K=48 zj9Qx#i9=y11!8HZhPlN1$YchTUg(xAlWhyg9~KP%XzU;6O1`?Nv%#aGorU9FSB%ZQ zF31!j8h(eO0FHXqSbM*bNV2$nRLy-RNhNz zaHuO!{Z5jY`f;O7!bQWBk}|^sZ~X-+qACsjb>`M7i4?HGD=64@+)@g8e>pI&DU0@PD=2_VR&PsD_VmD0 zr&^1mdar_(b{5?pkA5e-J&`i3(C7U4E0YAGp;>?Vo5SLa zoAKB>W^vezZDs{!gS00e5|)atdLM4|)PM_tNOHT3 z6+H+mMcGigSYr4bQeYE*Rgxs&CQ$d3CUEzAG?8d=c;T=Vb!~9a!v1t7ThS?3_)1sT zv+#rucbAQU?MH$loQC?3iyFV2Rr%KKb&t!9SjD`u9~?ml(zCIR@zfW3lm}WaXj1e5 zCt@N~E^=}%j1LlrvlkDzXkv+12VG&SkuW~;#yh59E<%GShaIJ!ue{;_Jvj7B-@SA^ z(7905FOac=;5FBzlpgNd(@{z|NM16NnA>q-U>qg?E+`hE#Q_ct|MChM{$KFFlaP5y d4**