This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b5269f7761c [opt](test) remove duplicate case and make concurrent to
accelerate regression test (#40021)
b5269f7761c is described below
commit b5269f7761c05657b58056995e3055ebc4c9d4c6
Author: hui lai <[email protected]>
AuthorDate: Wed Aug 28 20:13:18 2024 +0800
[opt](test) remove duplicate case and make concurrent to accelerate
regression test (#40021)
---
.../stream_load/test_stream_load_properties.out | 38 ------
.../stream_load/test_stream_load_2pc.groovy | 12 +-
.../stream_load/test_stream_load_properties.groovy | 135 +--------------------
3 files changed, 7 insertions(+), 178 deletions(-)
diff --git
a/regression-test/data/load_p0/stream_load/test_stream_load_properties.out
b/regression-test/data/load_p0/stream_load/test_stream_load_properties.out
index bc2a3c31a39..05f0d92d627 100644
--- a/regression-test/data/load_p0/stream_load/test_stream_load_properties.out
+++ b/regression-test/data/load_p0/stream_load/test_stream_load_properties.out
@@ -1342,44 +1342,6 @@
90 2023-08-27 true 22 16456 -1476824962
-3279894870153540825 8990195191470116763 26651.906
2.06860148942546E8 \N \N 2022-10-07T03:11:03 2023-03-18
2023-04-15T00:38:33 T L
QW0GQ3GoMtHgxPQOWGfVaveynahNpsNs09siMFA1OtO6QEDBQTdivmGyq7bFzejAqwbbVQQpREAmeLjcFSXLnQuou2KbwYD
\N \N \N \N true 1 2 3 4 5
6.0 7.0 888888888.000000000 999999999 2023-08-24
2023-08-24T12:00 2023-08-24 2023-08-24T12:00 我能吞下玻璃而不伤身体
我能吞下玻璃而不伤身体 我能吞下玻璃而不伤身体 \N \N \N \N
91 2023-08-27 true 90 2465 702240964
6373830997821598984 305860046137409400 15991.356
1.599972327386147E9 \N \N 2023-04-26T19:31:10 2023-07-21
\N 2
B7YKYBYT8w0YC926bZ8Yz1VzyiWw2NWDAiTlEoPVyz9AXGti2Npg1FxWqWk4hEaALw0ZBSuiAIPj41lq36g5QRpPmAjNPK
\N \N \N \N true 1 2 3 4 5
6.0 7.0 888888888.000000000 999999999 2023-08-24
2023-08-24T12:00 2023-08-24 2023-08-24T12:00 我能吞下玻璃而不伤身体
我能吞下玻璃而不伤身体 我能吞下玻璃而不伤身体 \N \N \N \N
--- !sql_json_read_json_by_line --
-2 [0, 0, 0, 0, 0, 0] [117, 117, 117, 117, 117, 117] [-4744, -4744,
-4744, -4744, -4744, -4744] [-1593211961, -1593211961, -1593211961,
-1593211961, -1593211961, -1593211961] [-3869640069299678780,
-3869640069299678780, -3869640069299678780, -3869640069299678780,
-3869640069299678780, -3869640069299678780] [8491817458398170567,
8491817458398170567, 8491817458398170567, 8491817458398170567,
8491817458398170567, 8491817458398170567] [-30948.857, -30948.857, -30948.857,
-30948.857, -30948.85 [...]
-3 [0, 0, 0, 0, 0, 0] [65, 65, 65, 65, 65, 65] [-4963, -4963,
-4963, -4963, -4963, -4963] [-1415431954, -1415431954, -1415431954,
-1415431954, -1415431954, -1415431954] [-3804309860450207000,
-3804309860450207000, -3804309860450207000, -3804309860450207000,
-3804309860450207000, -3804309860450207000] [8209240008557215376,
8209240008557215376, 8209240008557215376, 8209240008557215376,
8209240008557215376, 8209240008557215376] [-5058.13, -5058.13, -5058.13,
-5058.13, -5058.13] [1034763010.6 [...]
-4 [0, 0, 0, 0, 0, 0] [-67, -67, -67, -67, -67, -67] [-30372,
-30372, -30372, -30372, -30372, -30372] [181502941, 181502941,
181502941, 181502941, 181502941, 181502941] [-2062236823576972800,
-2062236823576972800, -2062236823576972800, -2062236823576972800,
-2062236823576972800, -2062236823576972800] [6357002962400127842,
6357002962400127842, 6357002962400127842, 6357002962400127842,
6357002962400127842, 6357002962400127842] [21235.783, 21235.783, 21235.783,
21235.783, 21235.783] [-110169 [...]
-4 [0, 0, 0, 0, 0, 0] [63, 63, 63, 63, 63, 63] [11399, 11399,
11399, 11399, 11399, 11399] [-583523026, -583523026, -583523026,
-583523026, -583523026, -583523026] [8801164674137231293,
8801164674137231293, 8801164674137231293, 8801164674137231293,
8801164674137231293, 8801164674137231293] [-8287675635310193906,
-8287675635310193906, -8287675635310193906, -8287675635310193906,
-8287675635310193906, -8287675635310193906] [23243.16, 23243.16, 23243.16,
23243.16, 23243.16] [716719993.249115, [...]
-8 [1, 1, 1, 1, 1, 1] [-11, -11, -11, -11, -11, -11] [-9648, -9648,
-9648, -9648, -9648, -9648] [-505356927, -505356927, -505356927,
-505356927, -505356927, -505356927] [7604760670442035037,
7604760670442035037, 7604760670442035037, 7604760670442035037,
7604760670442035037, 7604760670442035037] [1634770507625165798,
1634770507625165798, 1634770507625165798, 1634770507625165798,
1634770507625165798, 1634770507625165798] [10822.962, 10822.962, 10822.962,
10822.962, 10822.962] [1987551048.86 [...]
-16 [0, 0, 0, 0, 0, 0] [-43, -43, -43, -43, -43, -43] [13560, 13560,
13560, 13560, 13560, 13560] [-1743686513, -1743686513, -1743686513,
-1743686513, -1743686513, -1743686513] [7234719406392208769,
7234719406392208769, 7234719406392208769, 7234719406392208769,
7234719406392208769, 7234719406392208769] [-3871745630024229413,
-3871745630024229413, -3871745630024229413, -3871745630024229413,
-3871745630024229413, -3871745630024229413] [12225.427, 12225.427,
12225.427, 12225.427, 12225.427] [ [...]
-16 [1, 1, 1, 1, 1, 1] [-7, -7, -7, -7, -7, -7] [18655, 18655,
18655, 18655, 18655, 18655] [6240356, 6240356, 6240356, 6240356, 6240356,
6240356] [4552179257266841393, 4552179257266841393, 4552179257266841393,
4552179257266841393, 4552179257266841393, 4552179257266841393]
[323868824766329978, 323868824766329978, 323868824766329978,
323868824766329978, 323868824766329978, 323868824766329978] [2972.2478,
2972.2478, 2972.2478, 2972.2478, 2972.2478] [-1177167334.995008,
-1177167334.995008, -1 [...]
-17 [1, 1, 1, 1, 1, 1] [126, 126, 126, 126, 126, 126] [28165, 28165,
28165, 28165, 28165, 28165] [2032059721, 2032059721, 2032059721,
2032059721, 2032059721, 2032059721] [-2686776977990574879,
-2686776977990574879, -2686776977990574879, -2686776977990574879,
-2686776977990574879, -2686776977990574879] [-8498149444423102876,
-8498149444423102876, -8498149444423102876, -8498149444423102876,
-8498149444423102876, -8498149444423102876] [-21681.223, -21681.223,
-21681.223, -21681.223, -21681.2 [...]
-27 [0, 0, 0, 0, 0, 0] [-7, -7, -7, -7, -7, -7] [18307, 18307,
18307, 18307, 18307, 18307] [76399879, 76399879, 76399879, 76399879,
76399879, 76399879] [8050764818738996699, 8050764818738996699,
8050764818738996699, 8050764818738996699, 8050764818738996699,
8050764818738996699] [2402219865213589999, 2402219865213589999,
2402219865213589999, 2402219865213589999, 2402219865213589999,
2402219865213589999] [-16678.924, -16678.924, -16678.924, -16678.924,
-16678.924] [-2053879544.844726, -2053 [...]
-41 [0, 0, 0, 0, 0, 0] [-25, -25, -25, -25, -25, -25] [28704, 28704,
28704, 28704, 28704, 28704] [-437867812, -437867812, -437867812,
-437867812, -437867812, -437867812] [5508042206505207079,
5508042206505207079, 5508042206505207079, 5508042206505207079,
5508042206505207079, 5508042206505207079] [462527544684407597,
462527544684407597, 462527544684407597, 462527544684407597, 462527544684407597,
462527544684407597] [13629.614, 13629.614, 13629.614, 13629.614,
13629.614] [213722401.337962, [...]
-44 [0, 0, 0, 0, 0, 0] [61, 61, 61, 61, 61, 61] [-23419,
-23419, -23419, -23419, -23419, -23419] [378600280, 378600280,
378600280, 378600280, 378600280, 378600280] [6788166268039991679,
6788166268039991679, 6788166268039991679, 6788166268039991679,
6788166268039991679, 6788166268039991679] [-2814786606977504852,
-2814786606977504852, -2814786606977504852, -2814786606977504852,
-2814786606977504852, -2814786606977504852] [-20151.432, -20151.432,
-20151.432, -20151.432, -20151.432] [-124822 [...]
-48 [0, 0, 0, 0, 0, 0] [88, 88, 88, 88, 88, 88] [-18899,
-18899, -18899, -18899, -18899, -18899] [1953750640, 1953750640,
1953750640, 1953750640, 1953750640, 1953750640] [-6083034186246180312,
-6083034186246180312, -6083034186246180312, -6083034186246180312,
-6083034186246180312, -6083034186246180312] [7861718260607212662,
7861718260607212662, 7861718260607212662, 7861718260607212662,
7861718260607212662, 7861718260607212662] [20562.791, 20562.791, 20562.791,
20562.791, 20562.791] [-15979 [...]
-49 [0, 0, 0, 0, 0, 0] [126, 126, 126, 126, 126, 126] [31661, 31661,
31661, 31661, 31661, 31661] [359703581, 359703581, 359703581, 359703581,
359703581, 359703581] [-2399575246807057939, -2399575246807057939,
-2399575246807057939, -2399575246807057939, -2399575246807057939,
-2399575246807057939] [7684667782059034391, 7684667782059034391,
7684667782059034391, 7684667782059034391, 7684667782059034391,
7684667782059034391] [-504.68152, -504.68152, -504.68152, -504.68152,
-504.68152] [2121528 [...]
-52 [0, 0, 0, 0, 0, 0] [-7, -7, -7, -7, -7, -7] [-6985, -6985,
-6985, -6985, -6985, -6985] [826683531, 826683531, 826683531, 826683531,
826683531, 826683531] [-8966681855246736361, -8966681855246736361,
-8966681855246736361, -8966681855246736361, -8966681855246736361,
-8966681855246736361] [4814686163176635446, 4814686163176635446,
4814686163176635446, 4814686163176635446, 4814686163176635446,
4814686163176635446] [-6490.247, -6490.247, -6490.247, -6490.247, -6490.247]
[1076976372.033826, [...]
-55 [1, 1, 1, 1, 1, 1] [65, 65, 65, 65, 65, 65] [18805, 18805,
18805, 18805, 18805, 18805] [229725878, 229725878, 229725878, 229725878,
229725878, 229725878] [2742856458318615325, 2742856458318615325,
2742856458318615325, 2742856458318615325, 2742856458318615325,
2742856458318615325] [5907702768956232371, 5907702768956232371,
5907702768956232371, 5907702768956232371, 5907702768956232371,
5907702768956232371] [12354.624, 12354.624, 12354.624, 12354.624, 12354.624]
[1697579881.947477, 16975 [...]
-61 [1, 1, 1, 1, 1, 1] [121, 121, 121, 121, 121, 121] [31806, 31806,
31806, 31806, 31806, 31806] [-1410915562, -1410915562, -1410915562,
-1410915562, -1410915562, -1410915562] [-250403393155768717,
-250403393155768717, -250403393155768717, -250403393155768717,
-250403393155768717, -250403393155768717] [4301573778529723431,
4301573778529723431, 4301573778529723431, 4301573778529723431,
4301573778529723431, 4301573778529723431] [10719.892, 10719.892, 10719.892,
10719.892, 10719.892] [107378 [...]
-76 [1, 1, 1, 1, 1, 1] [-63, -63, -63, -63, -63, -63] [25799, 25799,
25799, 25799, 25799, 25799] [-1387912656, -1387912656, -1387912656,
-1387912656, -1387912656, -1387912656] [8967926767558546181,
8967926767558546181, 8967926767558546181, 8967926767558546181,
8967926767558546181, 8967926767558546181] [-3537865898119184476,
-3537865898119184476, -3537865898119184476, -3537865898119184476,
-3537865898119184476, -3537865898119184476] [5311.188, 5311.188, 5311.188,
5311.188, 5311.188] [17362 [...]
-84 [0, 0, 0, 0, 0, 0] [-10, -10, -10, -10, -10, -10] [9493, 9493,
9493, 9493, 9493, 9493] [-547874696, -547874696, -547874696, -547874696,
-547874696, -547874696] [-115057683458952756, -115057683458952756,
-115057683458952756, -115057683458952756, -115057683458952756,
-115057683458952756] [4473017779279230085, 4473017779279230085,
4473017779279230085, 4473017779279230085, 4473017779279230085,
4473017779279230085] [13718.372, 13718.372, 13718.372, 13718.372, 13718.372]
[-978213266.02697, [...]
-
--- !sql_json_read_json_by_line --
-2 [0, 0, 0, 0, 0, 0] [117, 117, 117, 117, 117, 117] [-4744, -4744,
-4744, -4744, -4744, -4744] [-1593211961, -1593211961, -1593211961,
-1593211961, -1593211961, -1593211961] [-3869640069299678780,
-3869640069299678780, -3869640069299678780, -3869640069299678780,
-3869640069299678780, -3869640069299678780] [8491817458398170567,
8491817458398170567, 8491817458398170567, 8491817458398170567,
8491817458398170567, 8491817458398170567] [-30948.857, -30948.857, -30948.857,
-30948.857, -30948.85 [...]
-3 [0, 0, 0, 0, 0, 0] [65, 65, 65, 65, 65, 65] [-4963, -4963,
-4963, -4963, -4963, -4963] [-1415431954, -1415431954, -1415431954,
-1415431954, -1415431954, -1415431954] [-3804309860450207000,
-3804309860450207000, -3804309860450207000, -3804309860450207000,
-3804309860450207000, -3804309860450207000] [8209240008557215376,
8209240008557215376, 8209240008557215376, 8209240008557215376,
8209240008557215376, 8209240008557215376] [-5058.13, -5058.13, -5058.13,
-5058.13, -5058.13] [1034763010.6 [...]
-4 [0, 0, 0, 0, 0, 0] [-67, -67, -67, -67, -67, -67] [-30372,
-30372, -30372, -30372, -30372, -30372] [181502941, 181502941,
181502941, 181502941, 181502941, 181502941] [-2062236823576972800,
-2062236823576972800, -2062236823576972800, -2062236823576972800,
-2062236823576972800, -2062236823576972800] [6357002962400127842,
6357002962400127842, 6357002962400127842, 6357002962400127842,
6357002962400127842, 6357002962400127842] [21235.783, 21235.783, 21235.783,
21235.783, 21235.783] [-110169 [...]
-8 [1, 1, 1, 1, 1, 1] [-11, -11, -11, -11, -11, -11] [-9648, -9648,
-9648, -9648, -9648, -9648] [-505356927, -505356927, -505356927,
-505356927, -505356927, -505356927] [7604760670442035037,
7604760670442035037, 7604760670442035037, 7604760670442035037,
7604760670442035037, 7604760670442035037] [1634770507625165798,
1634770507625165798, 1634770507625165798, 1634770507625165798,
1634770507625165798, 1634770507625165798] [10822.962, 10822.962, 10822.962,
10822.962, 10822.962] [1987551048.86 [...]
-16 [0, 0, 0, 0, 0, 0] [-43, -43, -43, -43, -43, -43] [13560, 13560,
13560, 13560, 13560, 13560] [-1743686513, -1743686513, -1743686513,
-1743686513, -1743686513, -1743686513] [7234719406392208769,
7234719406392208769, 7234719406392208769, 7234719406392208769,
7234719406392208769, 7234719406392208769] [-3871745630024229413,
-3871745630024229413, -3871745630024229413, -3871745630024229413,
-3871745630024229413, -3871745630024229413] [12225.427, 12225.427,
12225.427, 12225.427, 12225.427] [ [...]
-17 [1, 1, 1, 1, 1, 1] [126, 126, 126, 126, 126, 126] [28165, 28165,
28165, 28165, 28165, 28165] [2032059721, 2032059721, 2032059721,
2032059721, 2032059721, 2032059721] [-2686776977990574879,
-2686776977990574879, -2686776977990574879, -2686776977990574879,
-2686776977990574879, -2686776977990574879] [-8498149444423102876,
-8498149444423102876, -8498149444423102876, -8498149444423102876,
-8498149444423102876, -8498149444423102876] [-21681.223, -21681.223,
-21681.223, -21681.223, -21681.2 [...]
-27 [0, 0, 0, 0, 0, 0] [-7, -7, -7, -7, -7, -7] [18307, 18307,
18307, 18307, 18307, 18307] [76399879, 76399879, 76399879, 76399879,
76399879, 76399879] [8050764818738996699, 8050764818738996699,
8050764818738996699, 8050764818738996699, 8050764818738996699,
8050764818738996699] [2402219865213589999, 2402219865213589999,
2402219865213589999, 2402219865213589999, 2402219865213589999,
2402219865213589999] [-16678.924, -16678.924, -16678.924, -16678.924,
-16678.924] [-2053879544.844726, -2053 [...]
-41 [0, 0, 0, 0, 0, 0] [-25, -25, -25, -25, -25, -25] [28704, 28704,
28704, 28704, 28704, 28704] [-437867812, -437867812, -437867812,
-437867812, -437867812, -437867812] [5508042206505207079,
5508042206505207079, 5508042206505207079, 5508042206505207079,
5508042206505207079, 5508042206505207079] [462527544684407597,
462527544684407597, 462527544684407597, 462527544684407597, 462527544684407597,
462527544684407597] [13629.614, 13629.614, 13629.614, 13629.614,
13629.614] [213722401.337962, [...]
-44 [0, 0, 0, 0, 0, 0] [61, 61, 61, 61, 61, 61] [-23419,
-23419, -23419, -23419, -23419, -23419] [378600280, 378600280,
378600280, 378600280, 378600280, 378600280] [6788166268039991679,
6788166268039991679, 6788166268039991679, 6788166268039991679,
6788166268039991679, 6788166268039991679] [-2814786606977504852,
-2814786606977504852, -2814786606977504852, -2814786606977504852,
-2814786606977504852, -2814786606977504852] [-20151.432, -20151.432,
-20151.432, -20151.432, -20151.432] [-124822 [...]
-48 [0, 0, 0, 0, 0, 0] [88, 88, 88, 88, 88, 88] [-18899,
-18899, -18899, -18899, -18899, -18899] [1953750640, 1953750640,
1953750640, 1953750640, 1953750640, 1953750640] [-6083034186246180312,
-6083034186246180312, -6083034186246180312, -6083034186246180312,
-6083034186246180312, -6083034186246180312] [7861718260607212662,
7861718260607212662, 7861718260607212662, 7861718260607212662,
7861718260607212662, 7861718260607212662] [20562.791, 20562.791, 20562.791,
20562.791, 20562.791] [-15979 [...]
-49 [0, 0, 0, 0, 0, 0] [126, 126, 126, 126, 126, 126] [31661, 31661,
31661, 31661, 31661, 31661] [359703581, 359703581, 359703581, 359703581,
359703581, 359703581] [-2399575246807057939, -2399575246807057939,
-2399575246807057939, -2399575246807057939, -2399575246807057939,
-2399575246807057939] [7684667782059034391, 7684667782059034391,
7684667782059034391, 7684667782059034391, 7684667782059034391,
7684667782059034391] [-504.68152, -504.68152, -504.68152, -504.68152,
-504.68152] [2121528 [...]
-52 [0, 0, 0, 0, 0, 0] [-7, -7, -7, -7, -7, -7] [-6985, -6985,
-6985, -6985, -6985, -6985] [826683531, 826683531, 826683531, 826683531,
826683531, 826683531] [-8966681855246736361, -8966681855246736361,
-8966681855246736361, -8966681855246736361, -8966681855246736361,
-8966681855246736361] [4814686163176635446, 4814686163176635446,
4814686163176635446, 4814686163176635446, 4814686163176635446,
4814686163176635446] [-6490.247, -6490.247, -6490.247, -6490.247, -6490.247]
[1076976372.033826, [...]
-55 [1, 1, 1, 1, 1, 1] [65, 65, 65, 65, 65, 65] [18805, 18805,
18805, 18805, 18805, 18805] [229725878, 229725878, 229725878, 229725878,
229725878, 229725878] [2742856458318615325, 2742856458318615325,
2742856458318615325, 2742856458318615325, 2742856458318615325,
2742856458318615325] [5907702768956232371, 5907702768956232371,
5907702768956232371, 5907702768956232371, 5907702768956232371,
5907702768956232371] [12354.624, 12354.624, 12354.624, 12354.624, 12354.624]
[1697579881.947477, 16975 [...]
-61 [1, 1, 1, 1, 1, 1] [121, 121, 121, 121, 121, 121] [31806, 31806,
31806, 31806, 31806, 31806] [-1410915562, -1410915562, -1410915562,
-1410915562, -1410915562, -1410915562] [-250403393155768717,
-250403393155768717, -250403393155768717, -250403393155768717,
-250403393155768717, -250403393155768717] [4301573778529723431,
4301573778529723431, 4301573778529723431, 4301573778529723431,
4301573778529723431, 4301573778529723431] [10719.892, 10719.892, 10719.892,
10719.892, 10719.892] [107378 [...]
-76 [1, 1, 1, 1, 1, 1] [-63, -63, -63, -63, -63, -63] [25799, 25799,
25799, 25799, 25799, 25799] [-1387912656, -1387912656, -1387912656,
-1387912656, -1387912656, -1387912656] [8967926767558546181,
8967926767558546181, 8967926767558546181, 8967926767558546181,
8967926767558546181, 8967926767558546181] [-3537865898119184476,
-3537865898119184476, -3537865898119184476, -3537865898119184476,
-3537865898119184476, -3537865898119184476] [5311.188, 5311.188, 5311.188,
5311.188, 5311.188] [17362 [...]
-84 [0, 0, 0, 0, 0, 0] [-10, -10, -10, -10, -10, -10] [9493, 9493,
9493, 9493, 9493, 9493] [-547874696, -547874696, -547874696, -547874696,
-547874696, -547874696] [-115057683458952756, -115057683458952756,
-115057683458952756, -115057683458952756, -115057683458952756,
-115057683458952756] [4473017779279230085, 4473017779279230085,
4473017779279230085, 4473017779279230085, 4473017779279230085,
4473017779279230085] [13718.372, 13718.372, 13718.372, 13718.372, 13718.372]
[-978213266.02697, [...]
-
-- !sql_json_read_json_by_line --
2 [0, 0, 0, 0, 0, 0] [117, 117, 117, 117, 117, 117] [-4744, -4744,
-4744, -4744, -4744, -4744] [-1593211961, -1593211961, -1593211961,
-1593211961, -1593211961, -1593211961] [-3869640069299678780,
-3869640069299678780, -3869640069299678780, -3869640069299678780,
-3869640069299678780, -3869640069299678780] [8491817458398170567,
8491817458398170567, 8491817458398170567, 8491817458398170567,
8491817458398170567, 8491817458398170567] [-30948.857, -30948.857, -30948.857,
-30948.857, -30948.85 [...]
3 [0, 0, 0, 0, 0, 0] [65, 65, 65, 65, 65, 65] [-4963, -4963,
-4963, -4963, -4963, -4963] [-1415431954, -1415431954, -1415431954,
-1415431954, -1415431954, -1415431954] [-3804309860450207000,
-3804309860450207000, -3804309860450207000, -3804309860450207000,
-3804309860450207000, -3804309860450207000] [8209240008557215376,
8209240008557215376, 8209240008557215376, 8209240008557215376,
8209240008557215376, 8209240008557215376] [-5058.13, -5058.13, -5058.13,
-5058.13, -5058.13] [1034763010.6 [...]
diff --git
a/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
b/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
index 263281929d9..a193a3f503d 100644
--- a/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
@@ -27,7 +27,7 @@ suite("test_stream_load_2pc", "p0") {
// for test dup, mow, uniq, agg tables, we use sql statement concat these
parameters
// due to dynamic partition is different from others, it's the reason why
we concat create sql statement
- def tables = ["stream_load_dup_tbl_basic", "stream_load_mow_tbl_basic",
"stream_load_uniq_tbl_basic", "stream_load_agg_tbl_basic"]
+ def tables = ["stream_load_dup_tbl_basic_2pc",
"stream_load_mow_tbl_basic_2pc", "stream_load_uniq_tbl_basic_2pc",
"stream_load_agg_tbl_basic_2pc"]
def columns_stream_load = [
"""k00, k01, k02, k03, k04, k05, k06, k07, k08, k09, k10, k11, k12,
k13, k14, k15, k16, k17, k18""",
@@ -39,7 +39,7 @@ suite("test_stream_load_2pc", "p0") {
def create_table_sql = [
"""
- CREATE TABLE stream_load_dup_tbl_basic
+ CREATE TABLE ${tables[0]}
(
k00 INT NOT NULL,
k01 DATE NOT NULL,
@@ -95,7 +95,7 @@ suite("test_stream_load_2pc", "p0") {
DUPLICATE KEY(k00)""",
"""
- CREATE TABLE stream_load_mow_tbl_basic
+ CREATE TABLE ${tables[1]}
(
k00 INT NOT NULL,
k01 DATE NULL,
@@ -148,7 +148,7 @@ suite("test_stream_load_2pc", "p0") {
""",
"""
- CREATE TABLE stream_load_uniq_tbl_basic
+ CREATE TABLE ${tables[2]}
(
k00 INT NOT NULL,
k01 DATE NOT NULL,
@@ -198,7 +198,7 @@ suite("test_stream_load_2pc", "p0") {
""",
"""
- CREATE TABLE stream_load_agg_tbl_basic
+ CREATE TABLE ${tables[3]}
(
k00 INT NOT NULL,
k01 DATE NOT NULL,
@@ -566,7 +566,7 @@ suite("test_stream_load_2pc", "p0") {
def expected = [1, 3, 3, 5, 21]
// we recreate table for each partition, then load data with stream
load and check the result
for (i = 0; i < tables.size(); ++i) {
- if (isCloudMode() &&
tables[i].equals("stream_load_mow_tbl_basic")) {
+ if (isCloudMode() &&
tables[i].equals("stream_load_mow_tbl_basic_2pc")) {
log.info("Skip stream load mow table in cloud mode")
continue;
}
diff --git
a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
index 1e4e207821b..4f52caa10c5 100644
---
a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
+++
b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
@@ -31,7 +31,7 @@ import org.apache.http.client.RedirectStrategy;
import org.apache.http.impl.client.LaxRedirectStrategy;
import org.codehaus.groovy.runtime.IOGroovyMethods
-suite("test_stream_load_properties", "p0,nonConcurrent") {
+suite("test_stream_load_properties", "p0") {
def tables = [
"dup_tbl_basic",
@@ -1100,139 +1100,6 @@ suite("test_stream_load_properties",
"p0,nonConcurrent") {
}
}
- // test read_json_by_line with enable_simdjson_reader=false/true
- def backendId_to_backendIP = [:]
- def backendId_to_backendHttpPort = [:]
- getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
-
- def get_be_param = { paramName ->
- // assuming paramName on all BEs have save value
- String backend_id = backendId_to_backendIP.keySet()[0]
- def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
- assertEquals(code, 0)
- def configList = parseJson(out.trim())
- assert configList instanceof List
- for (Object ele in (List) configList) {
- assert ele instanceof List<String>
- if (((List<String>) ele)[0] == paramName) {
- return ((List<String>) ele)[2]
- }
- }
- }
-
- def set_be_param = { paramName, paramValue ->
- // for eache BE node, set paramName=paramValue
- for (String id in backendId_to_backendIP.keySet()) {
- def beIp = backendId_to_backendIP.get(id)
- def bePort = backendId_to_backendHttpPort.get(id)
- def (code, out, err) = curl("POST",
String.format("http://%s:%s/api/update_config?%s=%s";, beIp, bePort, paramName,
paramValue))
- assertTrue(out.contains("OK"))
- }
- }
-
- // read and save original value of enable_simdjson_reader
- boolean enable_simdjson_reader =
Boolean.parseBoolean(get_be_param.call("enable_simdjson_reader"))
-
- i = 0
- try {
- // set enable_simdjson_reader=false and test
- set_be_param.call("enable_simdjson_reader", "false")
-
- for (String tableName in tables) {
- sql new
File("""${context.file.parent}/ddl/${tableName}_drop.sql""").text
- sql new
File("""${context.file.parent}/ddl/${tableName}_create.sql""").text
-
- streamLoad {
- table "stream_load_" + tableName
- set 'format', 'json'
- set 'columns', columns[i]
- set 'read_json_by_line', 'true'
- if (i <= 3) {
- file json_by_line_files[0]
- } else {
- file json_by_line_files[1]
- }
- time 10000 // limit inflight 10s
-
- check { result, exception, startTime, endTime ->
- if (exception != null) {
- throw exception
- }
- log.info("Stream load result: ${result}".toString())
- def json = parseJson(result)
- assertEquals("success", json.Status.toLowerCase())
- assertEquals(jsonLoadedRows[i], json.NumberTotalRows)
- assertEquals(jsonLoadedRows[i], json.NumberLoadedRows)
- assertEquals(0, json.NumberFilteredRows)
- assertEquals(0, json.NumberUnselectedRows)
- }
- }
- sql "sync"
- def tableName1 = "stream_load_" + tableName
- if (i <= 3) {
- qt_sql_json_read_by_line "select * from ${tableName1} order by
k00,k01"
- } else {
- qt_sql_json_read_json_by_line "select * from ${tableName1}
order by k00"
- }
- i++
- }
- } finally {
- for (String tableName in tables) {
- sql new
File("""${context.file.parent}/ddl/${tableName}_drop.sql""").text
- }
- }
-
- i = 0
- try {
- // set enable_simdjson_reader=true and test
- set_be_param.call("enable_simdjson_reader", "true")
-
- for (String tableName in tables) {
- sql new
File("""${context.file.parent}/ddl/${tableName}_drop.sql""").text
- sql new
File("""${context.file.parent}/ddl/${tableName}_create.sql""").text
-
- streamLoad {
- table "stream_load_" + tableName
- set 'format', 'json'
- set 'columns', columns[i]
- set 'read_json_by_line', 'true'
- if (i <= 3) {
- file json_by_line_files[0]
- } else {
- file json_by_line_files[1]
- }
- time 10000 // limit inflight 10s
-
- check { result, exception, startTime, endTime ->
- if (exception != null) {
- throw exception
- }
- log.info("Stream load result: ${result}".toString())
- def json = parseJson(result)
- assertEquals("success", json.Status.toLowerCase())
- assertEquals(jsonLoadedRows[i], json.NumberTotalRows)
- assertEquals(jsonLoadedRows[i], json.NumberLoadedRows)
- assertEquals(0, json.NumberFilteredRows)
- assertEquals(0, json.NumberUnselectedRows)
- }
- }
- sql "sync"
- def tableName1 = "stream_load_" + tableName
- if (i <= 3) {
- qt_sql_json_read_by_line "select * from ${tableName1} order by
k00,k01"
- } else {
- qt_sql_json_read_json_by_line "select * from ${tableName1}
order by k00"
- }
- i++
- }
- } finally {
- for (String tableName in tables) {
- sql new
File("""${context.file.parent}/ddl/${tableName}_drop.sql""").text
- }
- }
- // restore BEs to original value
- set_be_param.call("enable_simdjson_reader", enable_simdjson_reader ?
"true" : "false")
-
// test invalid jsonpaths
i = 0
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
