From f341d14be8d52cf0122defe2bce85babee142a98 Mon Sep 17 00:00:00 2001 From: jarvis Date: Mon, 18 Sep 2023 19:14:44 +0800 Subject: [PATCH] [Feature] update assert sink check --- .../src/test/resources/json/e2e_lzo.json | Bin 3348 -> 3306 bytes .../json/local_file_json_lzo_to_console.conf | 23 ++++++------------ 2 files changed, 8 insertions(+), 15 deletions(-) diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json index 5abf6283cc84d87cd0cdae3d1d163554abfef8ea..ed3a4e789158f9a21b84e8fec6bf8c47677e5e83 100644 GIT binary patch literal 3306 zcmZu!OH5 z*ZIzOzK>5A*D|3S*S~%J_1DL4hTjcD6K^15WOz(>dUs zMsCx+-`?Lj3V?U3jqFPJ6CW#AI-N>C9Q&a$T5ClK@u}jRaU+cM0WAR{##e+WDx_vU z6-Hal06uaH9Cka~tp*k?#yiPrY*Jm{Xt$g7N-G@OtTYenZlt^2>TkEY;aJ3y!KA%P zvpE=`(z3zOOGKF#Oj|Ao>ufg$qe4?=h{Cp%F`S7p;a+bx+Z8NHqlyusRgxPwT5I<< znsp4b=-{i3ez$&z=vJqFhBK}7bnSwLF4k&Yz}#GOZw{|Zy`_EHyDX>o}7iPHk>I zN&@HV>EpHw-pqPDmy4HO@RXF28RlCB?yTn4r&KXS$uf?BDki`l9;Hx3DnltkH?zJP z6*f6bj}eL9m_Ovac08@ieGAhldhEkiXC%INv%&87I_;s9f9$=satp&M3f z#*`3tutsX`>2T;RiJ&lOhg)fwumFhj%=+wNCXUruRB|De;O8df&8#Of`RPU6jz*<1 zTrgpnwN_h;uoCn6_1DTl(kVYk78Zl~{QakI4<+J3a$VL z>Ft$c?0S?+)po(pNu$?V13q{(pX&p+w+buRF1qqH#RX0qnJrnE$GoCQHn+(bcM zzO~%UmD=>7H{{a(@jIYBbPLfFMmX8w!0uZrqLf%I6qqAYP$Hx`f14mgEJ97dSd3$d z(7mN%slJPArxVF?0yG@$OfSQR!l`WVs0UnFY#uld%N*tR_knZqwUndnWNu+~0l2(7 zmvz~Z$sP1IBUtgfI54-!BMsW5gtx=#d>r0FRzh>%GDTqFhWk(k&Wz{r+rJ;C+X=4oX+Y(_7m@wr1l6O@{4OK?4BtPq`=VK$)`K^<+LVSEAfQXQM zMlonkqN2Fn5TB?;6=4d(ms|=6+n$~gOcYK=RK55Ge?At9&Gn98nBky5lX177J__=1 zjPQJ;m2Uy}Q=2)LWsP7uxd`0Ow^B|tbKSkw6X2!UPR13a>S0hn@Uh@6PLwsAYggO| zRN}M@Vvu79JVqJJ!JhqXR8wu>l(5f|H+)oil-PV)wq;K|{^R6t#E!bGH~M8hCGcui}VV=^xjNz}uxgWF=(O+-)2H?_{Ry zj@Vpc^C*f1?5%`Ey7P2PUE8nGbl+bSd+^=L zh*4}KU@%gG0?pw;ChBSjGT%asI3H5&^d|%pDT-7;$ybJ9=Dqn^W!~9!da0P&!2Oaz zFy|`jNn$r}_uZ`pn-$=AKXFh4-l#9G?f^Gt3N_bWah<(-a{#sNF_s| z8E^olps?YQS$M8gNHHe|T+cO6k}D%!0|iGJ-dSjOTc>LiHIKYMWiR&cHaxt$J2rI% zcSD^!|MlI=v6~zeXpQP+QL2okRz3arMQ4;o;Y%3h=f9l19J>KNpl28$nl>lw=$B(7 zxk61;XoFTg8=ic>%R3z?^6?BjSaz|I+*i0@*Fj literal 3348 zcmY*c%TJ@%9W{^P%P=!0O+u73qRDusVJ3Vw_x74RqHl%~q+t_3h;= zL`Ip+G9CyWaP|A%oksh@K6o+on^yf`$(3e%adT}BEF~AFQdQu+nMA7qytmYv-2hIt ziwRe{X1cmP0UY1YO=f||miCi#z^%o(+41j}PHIkt#btfUl_AtJD}AH26XzlD){y4CC@GGJ0anE4Z>k!(K!Hjo_a_PiCPu15! zACr=UV#&Y*=LE7j@A_--2#aw6rgV~<6F!*s`lK|P;A|R93M){CH@m+Gy6$dlZDrFm z;dK%bW%~4~!GsrjLNc6}DZ%h;&Z!~XqLM}{ML4%gGa`uAXOEGD7v@n$vqS~N21G>O zc%%3BX*l#^B3-W4!O>K)K2Zi|^?If3I3L@nwM)PoOIvrBftSitnL2PQvAyFso|vEC zTLZ2fjAbW*i}lq)-uJywghK-a8ZtiY;qGh|^w059G6SbDN;L)Hpk8ug3FK@1({NWM zH$B>noV{*-8`h|W*TEz)$FH8g+(WgZ+7N3`ZafJ36a{1WYZ%uOVm0LUNw|l_v@*RJWl;R^akwj4Yh;s6avbi2;3&CxYVZyiwA5;?iP2IBOCQ>qzzft8 zqODcjLJpc9KQnyCy8^WnmL(z(ETH0|H+BpHbL;74gh6DqvNBo&A%*t#yd!93Vxi*j z*jgnw>IjREr^kV}TKUBc@Z?Ui=00C3jgB}GH`Z4+O8%l3dKOnR6c*(^)hH;63aTtf zu$BnnQ{xmV6h7uK8iz9sT7G zkay^D#Rzw&bKk{=u#t>GzBnI;ES0eWem|KXzTba^k|>o~Vgf+|DWgt#nZ459I4+)x z&#yQ)k51%sPD!a!yWId@Us;$c0mql-CyI`!`0Bb-W@)^TssL}Sr5Z`#gY3a{$`@Yf zhMJ!|GcApRHmv2)HdpGMi~H|iqA_GF+)Y03zluI!DAbR30Qd6P z=l$K;d@-IIE6}&$!24Ba+sCby3Q7zp`1j2@FTTUW5I>=dc8510Zz=;rX6#;m5~kC@(!D&`XO+x z)yypd7uF9GZhdlMa(>f)-3wi(3^uXc5+^Dg48AhlM-2t+X&E#}3?jufHO&})jDl1< zbJ^A097Kn!3I9L+=AJkXE@_QLkk)y9@In7If%U}gt_Wdhhwt>>+GM3+}HDLdGz6THcYW6`l7->Avk{P=x6<1 zXq7^%sPX!EOf&7~2soF)r)a4k40SK3ikW>!Qpy(qj{AxbRA8cOwr1Rt~a<>%hw+$;>wJ z==A8U!0`PLJotXkIt`;*+b9>dDZHGrdx6@f+W4}`M zzhI%Oh$hQ1MJi+#9u7mHBlrqK3Unn-{vEa!7Ihr}O;uswW6_U?I=9>V^_`>Z_Rm9< zoXHnphI`TTRu2LYv1lZ}kr;Aw2nGd?DU9GcSSvWk+yTo`h#RVmW`eMdNjMyx!eA{P zt&uw2`LVghENPP|uhWG&J$f3eLQf#*-2TWisxj-JvltqKBdui$t(l-;gvj&92)58s zDza3*6)^Np7i2S~g*_Mf^OLE4C#Yh1C!Yh3r%Q<(aCIVk5C>iwTPe%{x2Bhyj>+xT zQp%0ZcUN1x?(mQ6L14m@mlsK#o2}E5rtThrYmEykSoE z-wk&jG!NI(=T8p4?hWSxbNuYBZ~AfWn@6vl2N*w41dHL~^e5lC@x!$i3?!JlT+$PT z_1#Dy%9xD4`!LarPy#=gqBS(CW96W$vRRCmI8_6L50?Y90JJ5DlUb-up~SE(rWW*R j3#CdN&_cWSo*w>eD2xukNS3ic!m0+7+YkQ#pP&B$rxrB~ diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf index 12c4e626ffd4..37f25a2ff5c6 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf +++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf @@ -27,6 +27,7 @@ env { source { LocalFile { + result_table_name = "fake" path = "/seatunnel/read/lzo_json" row_delimiter = "\n" partition_dir_expression = "${k0}=${v0}" @@ -76,9 +77,10 @@ source { sink { Console { - + source_table_name = "fake" } Assert { + source_table_name = "fake" rules { row_rules = [ { @@ -92,7 +94,7 @@ sink { field_type = string field_value = [ { - rule_type = NOT_NULL + equals_to = "WArEB" } ] }, @@ -110,25 +112,16 @@ sink { field_type = double field_value = [ { - rule_type = NOT_NULL + equals_to = 12.4 } ] }, { - field_name = name - field_type = string + field_name = c_date + field_type = date field_value = [ { - rule_type = NOT_NULL - } - ] - }, - { - field_name = hobby - field_type = string - field_value = [ - { - rule_type = NOT_NULL + equals_to = "2022-05-05" } ] }