From 261ed7094792bfcfe04d54c48f39afa2100220a0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=A3=B8=E5=A5=94=E4=B8=B6=E5=B0=8F=E9=A6=92=E5=A4=B4?=
 <streakxin@foxmail.com>
Date: Fri, 24 May 2024 10:33:42 +0800
Subject: [PATCH] [BugFix] Fix the crash caused by JniScanner (#44903)

Signed-off-by: changxin <streakxin@foxmail.com>
(cherry picked from commit b8cbc29f099bdd89876c1f60e717419939a82cca)
---
 .../hive/reader/TestHiveScanner.java          |  46 ++++++++++++++++++
 .../test_complex_type/complex_type_test.avro  | Bin 0 -> 734366 bytes
 .../jni/connector/OffHeapColumnVector.java    |  29 ++++++++---
 3 files changed, 67 insertions(+), 8 deletions(-)
 create mode 100644 java-extensions/hive-reader/src/test/resources/test_complex_type/complex_type_test.avro

diff --git a/java-extensions/hive-reader/src/test/java/com/starrocks/hive/reader/TestHiveScanner.java b/java-extensions/hive-reader/src/test/java/com/starrocks/hive/reader/TestHiveScanner.java
index 0e0b06b844c6d..818fdb19f5ef6 100644
--- a/java-extensions/hive-reader/src/test/java/com/starrocks/hive/reader/TestHiveScanner.java
+++ b/java-extensions/hive-reader/src/test/java/com/starrocks/hive/reader/TestHiveScanner.java
@@ -44,6 +44,45 @@ Map<String, String> createScanTestParams() {
         return params;
     }
 
+    Map<String, String> createComplexTypeScanTestParams() {
+        Map<String, String> params = new HashMap<>();
+        URL resource = TestHiveScanner.class.getResource("/test_complex_type");
+        String basePath = resource.getPath().toString();
+        String filePath = basePath + "/complex_type_test.avro";
+        File file = new File(filePath);
+        params.put("data_file_path", filePath);
+        params.put("block_offset", "0");
+        params.put("block_length", String.valueOf(file.length()));
+        params.put("hive_column_names",
+                "id,array_col,map_col,struct_col");
+        params.put("hive_column_types",
+                "string#array<string>#map<string,string>#struct<uid:string,device_list:array<string>,info:map<string,string>>");
+        params.put("input_format", "org.apache.hadoop.hive.ql.io.avro.AvroContainerInputFormat");
+        params.put("serde", "org.apache.hadoop.hive.serde2.avro.AvroSerDe");
+        params.put("required_fields", "id,array_col,map_col,struct_col");
+        return params;
+    }
+
+    String runComplexTypeScanOnParams(Map<String, String> params) throws Exception {
+        HiveScanner scanner = new HiveScanner(4096, params);
+        System.out.println(scanner.toString());
+        scanner.open();
+        StringBuilder sb = new StringBuilder();
+        while (true) {
+            scanner.getNextOffHeapChunk();
+            OffHeapTable table = scanner.getOffHeapTable();
+            if (table.getNumRows() == 0) {
+                break;
+            }
+            table.show(4096);
+            sb.append(table.dump(4096));
+            table.checkTableMeta(true);
+            table.close();
+        }
+        scanner.close();
+        return sb.toString();
+    }
+
     String runScanOnParams(Map<String, String> params) throws IOException {
         HiveScanner scanner = new HiveScanner(4096, params);
         System.out.println(scanner.toString());
@@ -70,4 +109,11 @@ public void c1DoScanTestOnPrimitiveType() throws IOException {
         Map<String, String> params = createScanTestParams();
         runScanOnParams(params);
     }
+
+    @Test
+    public void complexTypeTest() throws Exception {
+        Map<String, String> params = createComplexTypeScanTestParams();
+        // if error, NegativeArraySizeException will be throw
+        runComplexTypeScanOnParams(params);
+    }
 }
diff --git a/java-extensions/hive-reader/src/test/resources/test_complex_type/complex_type_test.avro b/java-extensions/hive-reader/src/test/resources/test_complex_type/complex_type_test.avro
new file mode 100644
index 0000000000000000000000000000000000000000..c013a43a7b0b99d8bf7d5788d9904efdd19dc0f6
GIT binary patch
literal 734366
zcmeI*K~G%g6~=LTDoRv!g+^UhtSu`f5aS_a(=AdLv>T$xn!pU1Y77=&r)iXL!xvy#
zsS+Om7JLBIJ!0EEeec*#2mFqC;ohsr&TpBRjGgN<&+|Xed(M0R^6lS$^T{83ulDyI
zA8dWsf8P7gAAVdo{NY7^p}Vl(-`d;XUU;;y+k0O9^VZ(;7o+|^o>jm6?67}u_~w@m
zUi7xcKi~U)yLZ@2|8_9!kG2mMx?lhJ_P-rgpY!^2zh2mVIU1#ZJUHAR?(Qsn^Jrna
zKj^(29WHdMU-{|L&;M0#f4}#`v#q`Ar*HnpKmQ@eKazfVc-Vhl{f@Uk{HOPP{PW(6
z_kVc$f%MU@dZU;9`+j!%pL@A=`2LT-{eWNp^RrLW?^!+ax6d{G<M!TG`U`mdnP0vf
zZg*clyGPsoSHrFTv(fP2usePdU%vi@uO1C|2YcQ0=YR7r9=-YZU!@Ow_irbCV*2+t
zpYY^g&)eU<`s<qhw>9yHdFRva_xCma{cimKyyv&A{!gd>ekFf}<KOPxXZ6nS`OUk<
z^vzFy`hGvv-u~mm;q(6Ef9~z}fA_b){`u{{e6hbb>c2P~Zhex<q2GP;qt#D6-rC!J
z)!#oD?(IGv^>=z(Km2~s8y)m#x~uair|0XN7i*oX!SVIR+3eBfT*P8@B6<<uMr=iF
zNAx2G5jzpzMGPZGGwBD?uP;_V@mcjVpI1M%RQ=p?^^;#zKl`Nm>6Pl|pT;QS)0t@T
zll_rB<!s3*427XE=yJJ9Q4ESfF(?MbfcQ209ah3hSP3g(C9H&%h!NAbpz%x<V_*!7
zfiW-!#=saD17nPjnqd(vf<>?h7QrG|1dCu1EHaHaeKZp<<7K>zm+>-Q#>;paFXLsr
zjF+u--E+rHBc+kjNNJ=rQW`0ZltxM;rIFG|X{0n#8Yvg2G;xcJ4qJz<!`5Nzuyxov
zY#p`^TZgT~)?w?gb=W#=9d_yq+*#Ys1-_ye(TnIs^dfo@y@*~!FQOOGi|9r4B6<<M
zh+af5qL<bZlGZ-Bz1KbYBTI{<MbaW^k+eu!BrTE_NsFXK(jsY*v`AVcEs_?smXNge
z!P26M_nCXj0xkiUfJ?w7;1X~NxCC4RE&-Q-OTZ=I5^xE)1YE5pB&~h0fJ?xY&2$uo
z!cZ9fJJLS7EE3OtOB9B}P#AZpC&s`S*)NI0P#6jWe3qXyQw)khF(?Mbh=&ZPXjiqX
zS@~2L3PWMYG0J_FVo(f<K`|)CLqJ@PA;-w7r@~Me3PZqEZmSf7Vo(f<K`}()HP<y+
z2`gbGtb~=Y5>^t8t^PYJaaNM`RfVB26ox~za^RvE6oX<=42t2{y=IHXN>~XiVI{1D
zm9Ub=!aj#+4$-o<sxTCW!f?7;&RZ0NVo(f<K{3o@)a=k$2`gbGtb~=Y5>{fgFGb$z
zZ5Bxlwwrqv7z1Nq42*#>Fb2kG&Q}fU7}Ux7s=`nh3gZ`=;Oef<pPZhrZ(gi*t_H`~
z8)vgemvhlx57gc#lMymPMt&g~p%}x7)P%@QJPf)_m+3NHF3-~_2F0Kl6oX<|>8Y8(
zvl3RqN>~XiVI{1@c4!*|V;BQtU<{0bF)#+kz!(@KKAmwO>_9knU=b{WMX(4K!6H}$
zi((~U5iF|2a5)AMUrc!x1}F_sW_t&Pp)eH2UGnKf%869=TcR)&hQa`!GC7%?Oim^z
zlatBG<fi9Pco{F_WxR}+@iJb<%Xk?t<7K=YvE&T<v+CmQ&#SAq?|v8>DUFmyN+U%v
zG*TKVjg&@8Bc+kjNR{*sW<Je)W_t&Pp)eGNVc_znl44K{ia{|bhIhNwjG<TwD`6$9
zgq5%oR^m0GZJcOe42*#>Fb2lJ7#IU%V2tt91T2C@um~2xB3J~AU=b{WMR9AI)WVU4
zqbwsT427XEY@(Gn4-|u9Pz;JeF;b(o7~e+RXY*fJE3D0`r@~Me3PXxtZmSf7Vo(f<
zK{1^BIrnq!=iJY^pL4(Im&o8{yo{IeGG4~Zco{F_WxR}+@v<A+ongmlCOWVP7QrG|
z1dCu1EP_R_2o^=`M8G0g1dCu1EP_R_2o}L2SX903GigCOP9HS!Fl<%Ys>}|jC=7+6
zFs$2_Pc2alia{|b2E|C3odx}2Xjhx)(5w$wAIRFO!cZ6r!(K@_Z&3`2K`|%>#V~Sh
zw#Xrx*&?$=W{b=gnJqF~B&-$Ink{mM?F>7ckSGj=p)d?Llt*V2gJMt&ia{}qL)8r1
zSqUp)C9H&%u##F<(p{ZDIXz$Byjbg84UVrj&SsA;=c-}lPE;r2DFsg@*5Gzwd!Ou&
z%o155OJs>Gv6dxrzqF|HG)7?*#wd(Y7^5&oVT{5Ug=x4E)~;d<?W%TFyQ*E)t~Pdi
zoqTzscgGkQ17lzejDayQ2F6I=g2oT@F$TuK7#IU%U<{0bF)+q>YyuX+B3J~AU=b{W
zMX(4K!J=3RleN`bY@bx`vAy{)@G@Rj7<d^k<7K>zm+>-QzJ-WJ`;7Kw5m8|%429t(
zCgr^Y#h@4zgJMt&uRW@nHn0*_!b(^PD`6$9#2fV52(B>(#=saD17lzejDayQhO0>p
zP`aAb)ugT_bv3E0NnK59eZcxaHX%_M3PWMoD=Cl8C<eu#7!-qI*hH%twzCpe!b(^P
zD`6$9#8Pt`=e8IFV_*!7fiW-!#=saD!^J5sPMJO%hL`a&UdGFK8872yyo{IeGG4~Z
z5lfXAF2`W{v#^J44?EjCC=7+6Fz%91(TnIM`z=uz3PWLlPnn!dP9`UllgY{CWOCDU
zD7=i9@iJb<%Xk?t<7K>zm+>-Qc7}b=`v5gk8YzvGMoJ^4k<v(Mq%=|*DUFmyN+YF_
z8qGxKL9d%J3~U%U+f*tHg`qG^iI=Ah6oX<=42nT99z^1fcO36z<x^oO429v`uiRHD
z2F0Kl6oX=z6fh}ZQoy8uNdc1rCIw6im=rK6(8Md)b=W#=9kvczhpofbVe7DU*g9+-
zwhmi|t;5z~>#$Q_upO`n7QrG|1dCu1EP_R_=)=IG?&|!>>G}HR#aicTaD2USHhXkA
z7wxS#wfD)6sT@-|rgBW>n94DgV=8%!JVqWPkCDg7W8^XN7<tTxk;jN$h7&i-NQ)*O
zhJZ`JCEyZp3AhAY0xkiUfJ?w7;1X~NxCC4RE&-Q-tF?rrwGS3>3AnPEj>1qF3d05C
z<zXMipcoW`Vo(gPB&c~jz)DyND`6$9gq5(8=I*u-BbwmK`l`ZE7z)E^Upa7542nT9
zC<eta3|zBCV<oJFm9P?4!b(_)y%KvR_DbxP*ekJDVz0zriM^847r5U)s!4#P2hBbV
z(TnIs^dfo@y@*~!FQONWA$k$Lh+af5q8HJN=%v}T!CIHKu58+%FcgNuu<utMLs1Nh
zK`|%>#jqh<Gq`3Ytb~=Y5>~=WSc%If+BgHn7#IU%U<{0bF)#+kz!>8>D_8`JU=b{W
zMX(4K!6H}$i{jS&xfMk#idjZf7z#sS*j+7e9w-LIpcoW`Vx&fEG48qICae|KX4O++
zC=7)m#V@y2ia{|b2F0Kl&i$PGIrnq!=iJY^-}Gyz@G@S;%Xk?t<7K>zm+>-Q#>;p)
zy%uAsy0m&Z2GbvgsTWf(+2%oEC=7*hhkA-$L@(JdiNa7A3Ilw~<YaO(IhmYHP9`Ul
zn;t{qWxR}+@iJb<%Xk?t<7K>zm+`VQY<t-8;CGEW!*+(9?J5<9!cZ878_MGbia{|b
z2F0KlDVlLR)G%}<5jzpWT4AlQR#+>n71j!Cg|)B<7DZ~3k`|<Cmb7?SpAkhbq8HJN
z=tcA*dZ`&Vuo701v6AlU{K@J0`sT%2=W1|#y>T{sbU9bWoSmq~F%#7{OEm3$vOlr{
z&lI>?PJ#W?7=@rtP$#Gp)CuYYbxmYbNN&Pc!6(K5pMp9;ouE!o*Vy?N#=sa^TU8he
zLt(fyqnx)W2F0Kl6oX>8W~XL{#!6TTD`6$9gq5%o)9&Wv%odp~GFxP}$ZV0>BC|ye
zkIb7bGFz058x)4ZP#A{J%5x}+K`|%>#h@6*RBI;Jtb~=Y5>~=WSP3h!@zBO0D8|4T
z7z1Nq42*#>Fb2jL4_d(@SOkk;5iEj5um~2xB3KkF;hxXxjSEkz_j28Q7<d^kD-67h
zm+>-Q#>;paFW*8$S9-Y8Ba4U%Lt!WkcfFMN4itl8Pz;JeG29MSGi_ictb~=Y5>~=W
zSc!`U+X${P2FAb`7z1Nq42*#>Fow&F4N$tw*k#5pGj^G=%Zy!SY<<A`KsF&!7z#sS
z*efZI&L{@OpcoW`V%S8h8Md<$R>DeH2`gbGti)1t8|Std17lzejDayQ2FAb`7{kRW
zE>4*~8-|zhGG4~Zco{F_WxR}+@iJb<%MnYJ7%s<P`m?ZyZ4W!!J17i=p)l@}Ptl9$
zCHpN=7z#sSfKQp6Oim^zlatBG<YaQwb11xwm+>-Q#>;paFXLsrjF<5;UUr6k&-(y1
zQW`0ZltxM;rIFG|X{0n#8YzvGMoJ^4ks8fJ=RvQVF$`=NINMYz427XEOo^AL4HSc7
zPz;JeF&;$Xj&~gIWaU#~C=7+++^^hMDF(%$7!>0pR*dfI{K@J0`sT%2=W1|#y>T{s
zbU7F8MG)<MGO;Gs#F|)t#9~dChZE5-E17s0+>iTlKkmo<3^f~SHq>mW*-*2gW<$+}
znhiA@YL3{6fJLwf7QrG|1dCu1EP_R_D8;4Q0gGS}EP_R_2o}L2SOkk;QET%wt$na@
zDC1Ds2_S``FcgM;^77Fzia{|b2F0KlZlI_+HNi?)2`gbGtb~=YlID(@#fbL(vc9S?
z6o$gE2wDzY6oX<=42nT9td7@g(O3y9VI{1Dm9P?4Vz0zriM<kgCH6|}mDnq>S7NUu
z^##^#qnZRrdeH2{5WR?AL@%Nj(TnIs^dfq}7@`-^i|9r4B6<<Mh+dja8?1F%>&m7L
z3PWKi4EuiNF%-q17!-qIPz)QwHG^wb!b(^PD`6$9gq65#qKz|9jDayQ2FAb`7z1Nq
z42&_Jvw}si2o}L2SOkk;5iEj5uqbZLpIcG1qL^hwg`qGMhTYZj=7C~R42nT9C`M|u
z7UP~PZo*n&ZB{)MhQd%7Qv7mTr5F^0Vo(f<;oQ%;pL0Lwe$M@z`%S-g3NPbjyo{Ie
zGG4~Zco{F_WxR}+(`zx7s!OYvV=(<;n0hhwl5HLohQd%7cc`c6Mf8&Wk|+#?p)kOw
zOim^zlatBG<YaO(x#=+!UdGFK8872yyo{IeGG4~Zco{D{!?uSV4}RCEGi+zr*{)Jy
zC=7*RxS>35pcoW`Vo(f<k)j#5Lk&Y$60s8@tQFP@YlXGKT4AlQR#*#*U{RzdDQQ8P
zW=V^O^%+t0B6`V0FWuGolhgC{&5O0p)!_Jg<81cma<1x4J5kNhBq?sT4BPu;e`E!o
zDR8x%QkJJN3f-0NN_VBZ(p~AUnrJAH+=Q=!PmBRR9c(+;cCcOZFqf6E5>~=WSP3g(
zC5@ebX;-zYSzA>Y3PWMIG^3oiC<eu#7!-qIxMrtjhsH`+2`gbGtb~=Y64UNRu8pZ0
zQ#Gb)Ox2jGF;!!#4R2qWEizk_jT;n(!cZ87&dPHria{|b2F0Kl##C!2*Q|t<uo70n
zN>~XivGLHxAt=Vc7#IU%U<{0bF)#+k7!O*(B3J~AU=b{WMX(4K!6H}`E8)uM>WvFe
zs`ql;d>D8cFDneZjF<5;UdGFK886>LL|1ya(j$wA3PWKi40pYh_YM?;Vo(f<K{4D8
zRWog1C9H&%uo70nN?3`D2HOa(F$TuK7#IU%U<{0bF))V9j15q_%-ChdE;DwSvCE8I
zW^8@H`am`zQ5XtCVc07vkIpCt#h@4zgJRf3s~NVl5>~=WSP3g(C9K3!a~tQj7z1Nq
z42*#>Fb2lJ7#PFFDK1W#J{yLY@iJb<%Xk?t<7K>zm+>-Q#>){)l^8C^VEVJLhiwl#
z+dC)>g`qI+l26f#=q39tQ5XtCVSrDWoJ>w8CzF%O$>d~m({m`ijF<5;UdGFK8872y
zyo{IeGG2Cueb4&<HBuTWjg&@8Bc+kjNNJ=rQW`0ZltxM;rI8xVMCU=Tn=uS*7&zNh
zDh!38FieS;rwtT?Vo(f<K`|ag;*NJ5?_}juVJM7`qcFOw^Cze0>zfyAovXp|^~Txk
z(dAsU$BpfMvhSqt<j3)y^z|D~v~3h);$aXuB1hy59F;fp6oX<=42nT9j3^pWG@@uk
z(TJiEMI(wv6pbhvQH<D$fJLwf7QrG|1dCu1EP_R_D8;4Q0gGS}EP_R_2o}L2SOkk;
zQET%wt$nZoN&}SH2_S``FcgOE(DKnRia{|b2F0Kl_Q`8bO|TMH!b(^PD`6$9q`9MJ
zF`|9Htgk8zg`qGkf|dgp#h@4zgJMt&tK&6WG*-e&SP3g(C9H&%*ekJDVz0zriM<kg
zCH6|}mDnpueSvk`s3rlD9yI$fL@%Nj(TnIs^dfo@y@*~ghUi7~B6<<Mh+af5qL*gV
z25Vi`y0U45!cZ6r!@gg63`H?02F0Kl6vKva&ET4quo70nN>~XiVI?k`XyXhNV_*!7
zfiW-!#=saD17nQmtY8r=f<>?h7QrG|1dCu1EQ(w6=T;Q0C}tT^VJHlRVRyB>d7u~+
zgJMt&ijf+v#kl8+o3K_`n^jMRp)eGN6u;b7DF(%$7!-qIIQMhz=iJY^pL0Lwe$%g=
z!pnFWFXLsrjF<5;UdGFK8874I^jeIi>eA}v7)*Z{rd~|FWSa+tp)eH29qK815xr!;
zBnm@eC=Bo^latBG<YaO(IhmYHZh8!bm+>-Q#>;paFXLsrjF<5;UdGGLu<c>TgWomk
z4BHuYwyRVa3PWKSZYYl%C<eu#7!-qIq-e(NP{YubMC?QeYlXGKT4AlQR#+>n71qKc
zSQM#AN?MSnS<>QRT}JG#&Yzr~uWw$gb*=`-*BfWEN0)O|3(|>dR3d%jn*80O#ZUG}
z79oj{L`Whe5mL?Agq5%oR>DeH2`gbG4RxA&zevYgPh%A0I2&X9|5>ybH+agPGLl1b
zNDj#%IV6|91&tqRU<{0bF)#+kz!(?<V_*ycSFGF!`vhE)&nzM;427XET+CJ8J5UUY
zK`|%>#c-8h&9s4)uo70nN>~XiVI@s%)U~+c#;_SS!)DkFn_)9-hTX<VGseIe7z1Nq
z42*#>Fb2kO`=Hwg-9G5{!L&H^S#=xQ=hf|NOVyn7a&-gS7u6kXPpX@G&3sOM7<Q!W
zNM*kz3PWKi3|3O^s}zG`Pz;JeF|6Cx3@BL%D`6$9gq5%oR^sM{HqN>*2FAb`7z1Nq
z42*#>FoxTqObSdNo50I>8872yyo{IeGG4~Zco{F_Wh2-3oIlq{X{0n#8YzvGMoJ^4
zk<v(Mq%=|*DUFmyYBUp_2VHOCb||+)Wt&Qcp)eH2U3Wsr<YaQ$Z;8TC7z#sJE36gP
z3TuV6!dhXiuvS<rtQFP@Yooei6BfZDSOkk;5iEj5um~2xq7;{=yV%pITe^q6J|a59
zc7~ljgi#m@Ltz+hC_kN}7!-qIPz;LkpfO|PP{yIM@~JQshQcr>SMIA6gJMt&ia{|<
z)*2ykR$_$22#FCABP2#hjF1>1X<}?bhpofbVe7DU*g9+-whmi|t;5z~>#%j$I&2-b
z4m<S)mNcT8gG+kQ?86Yfh+af5q8HJN=tcA*dchc?7txF8Mf4(i5xt0BnoS!lHCt-V
zrVR>1VJHmS?&UEQ#h@4zgJMvOU&s9z-PQS%)ARMsi?z<x;P`suZ1(7KF4}W}_CDE>
zt0UK}b14jkp)j1qmm>|upcoW`Vo(gzJEnI`@0i{(y<>XE^p5Er(>tbjOz)(=z~Yp}
zsZqcpSOkk;5iEj5um~2lc5u|%2b;$*@0UI5QWy$DVHgB0KLe#06oX<=42tpV7#%ky
zKAaGI?l<u;w5tXvvnZf26o$euSzFGC6oX<=42nT9%;KBHH;Zo;-_V(%Gec*F&J3Ly
zIx}>Z`U11~X7SD9r{-uSoJhrvv`AVcEs_>Vi=;);B54sUk`_seq(#yqX_2(3wRxJ>
zKG<Zf$=YnDqc9YP!mw~u9`;cTia{|b2F0+VSo3&*m9P?4!b(^PD`6$k*io|>(Y{~S
zR~3fBP#8x0%7KewPz;JeF(`&%;F>KOD`6$9gq5%oR>Dde3;P_RIYi6as=`nh3d8AY
zId4%6ia{|b2E{OsQL{s1C9H&%uo70nN?3`}zBVqA!5A0=V_*!7fiW-!#=scki|Swz
zEP_R_2o}L2SOkk;5iGj>UIVlEX7RI(s4x_U!my-K-aJqYia{|b2F0+}RWoj2C9H&%
zuo70nN?3^v;Wm<MjDayQ2FAb`7z1Nq42<FJw%%^*?Y7=->+QDQZtLx~sV~@WZf4Ld
zzFGWi+MqBLhQhF<Q658442nT9C<eu_)>SjOW+kkIm9P?4!b(_4b7`O1BC|zVUsV_i
zLtz*?D+ex$K`|%>#h@6*RBN_qtb~=Y5>~=WSP3h!@nGZO!`yi2uFjvFp096StaYvi
z$JZNYvqzV6(cW2Zd!LL*5h)@?q=*!eB2q+(NIy&>1)sx-K|;Jd@h~7h#E1A0AL2uN
zh!620KE!v;j%#*Yv*Vf_*X+1vC-nuc*@<fXEa^eB4@2}KdJ(;dUPLdV7txF81!IU_
zL@%Nj(TnIs^dfp`Hf=EVV(KNEHYf~*p)g!BR~|!A42nT9C<euFEoIH%nw78;R>DeH
z2`gbGZa8k^3>0Hv42*#>Fb2lJ7#IU%jOVOi5iEj5um~2xB3J~AU=b{eTl42u6s;&`
z8Bt*<425BLwY+(t7!-qIPz;KZ8m+~+=Zc%KR#=-=Plcf{6owSP+*T<D#h@4zgJL-M
zbMEKd&$*v-Kj(haubslnco{F_WxR}+@iJb<%Xk?t<K^^PjHT+*>g5<re;B4-Oub~A
z2Zf<96viFuDS8pTWWOW|Lt!Wk@F|m%$;sqoaxyuYoJ?+d4275RGG4~Zco{F_WxR}+
z@iJb<%g(UvVaJ2tHR=r88Fsd-R2T|FVHj>Gj~gfk#h@4zgJPs;#_dqU(3M2&L<nnz
zwZd9qt*};DE36gP!Xj7{sYyy&kfvGE;$eM86upREL@%Nj(TnJ%X57F^SP3g(C9H&%
zu#(0)G}}A2ce1vsFcgNuu+~-1TNHz0Pz;JeF)V`C?9f;VD`6$9gq5%oR$?B*n5r>V
zW2(kfjj0+_HKy9cWTp;VhpofbVe7DU*g9+-whmi|t;5z~>#%j$I&2-bMNkVz7LKwB
ziNa7A3d1H^d35%{DMoj7{^az0ee+_ib2T`=-uQR?_g}xQE|2R(6_+JMPXF@_-V@Q@
zC;KB4Yhq2TKVq?_%jrtbr!fi%t^`+tE5ViEN^m8(4Yz0-DU6|!(nx8fQUK;H3f`j7
z%niAc&xzh0V_*!7fiW-!#;7@z&PrGbD`6$9gq5%o*9E6<LE}?P7z1Nq42*#>Fb2lJ
z7#L$bfd`9V5iEj5um~2xB3J~AU{S1uC5`HZ+D{@$;?0MFm+`W~z{_|UFXLsrjF<89
zEkraWZc03hhzdhtC=A!Qm-h}7gJMt&ia{~F_@QRnz)DyND`6$9gq5%o?+|JuxW*V5
z17lzejDayQ2FAb`Zn-u<>6UA^T)XAkE!S?jcFVQ(0qX<VghXK|jE|!*ZoiK1f8#)L
A=l}o!

literal 0
HcmV?d00001

diff --git a/java-extensions/jni-connector/src/main/java/com/starrocks/jni/connector/OffHeapColumnVector.java b/java-extensions/jni-connector/src/main/java/com/starrocks/jni/connector/OffHeapColumnVector.java
index f99e2bd41d40f..3ec16c1de9525 100644
--- a/java-extensions/jni-connector/src/main/java/com/starrocks/jni/connector/OffHeapColumnVector.java
+++ b/java-extensions/jni-connector/src/main/java/com/starrocks/jni/connector/OffHeapColumnVector.java
@@ -142,18 +142,31 @@ private void reserveInternal(int newCapacity) {
             this.data = Platform.reallocateMemory(data, oldCapacity * typeSize, newCapacity * typeSize);
         } else if (type.isByteStorageType()) {
             this.offsetData = Platform.reallocateMemory(offsetData, oldOffsetSize, newOffsetSize);
-            int childCapacity = newCapacity * DEFAULT_STRING_LENGTH;
-            this.childColumns = new OffHeapColumnVector[1];
-            this.childColumns[0] = new OffHeapColumnVector(childCapacity, new ColumnType(type.name + "#data",
-                    ColumnType.TypeValue.BYTE));
+            // Just create a new object at the first time, otherwise the data will be lost during expansion,
+            // and because the OFFSET record is continuous, the new offset address starts from 0 during the 
+            // expansion, which will cause the offset records to be negatively numbered. After being passed
+            // to BE, it becomes a non-sign number. This is a very huge number. When processing, the array 
+            // will cross the boundary, which may cause crash.
+            //
+            // The child's capacity is not expanded here because the child's appendValue function is used 
+            // to add data to it will automatically expand.
+            if (this.childColumns == null) {
+                int childCapacity = newCapacity * DEFAULT_STRING_LENGTH;
+                this.childColumns = new OffHeapColumnVector[1];
+                this.childColumns[0] = new OffHeapColumnVector(childCapacity, new ColumnType(type.name + "#data",
+                        ColumnType.TypeValue.BYTE));
+            }
         } else if (type.isArray() || type.isMap() || type.isStruct()) {
             if (type.isArray() || type.isMap()) {
                 this.offsetData = Platform.reallocateMemory(offsetData, oldOffsetSize, newOffsetSize);
             }
-            int size = type.childTypes.size();
-            this.childColumns = new OffHeapColumnVector[size];
-            for (int i = 0; i < size; i++) {
-                this.childColumns[i] = new OffHeapColumnVector(newCapacity, type.childTypes.get(i));
+            // Same as the above
+            if (this.childColumns == null) {
+                int size = type.childTypes.size();
+                this.childColumns = new OffHeapColumnVector[size];
+                for (int i = 0; i < size; i++) {
+                    this.childColumns[i] = new OffHeapColumnVector(newCapacity, type.childTypes.get(i));
+                }
             }
         } else {
             throw new RuntimeException("Unhandled type: " + type);