This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 0552820d5cb branch-4.0: [env](case) remove disable pipeline engine
case #57046 (#57109)
0552820d5cb is described below
commit 0552820d5cbde4576968309b02ec900a7e2ce212
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Oct 18 11:15:22 2025 +0800
branch-4.0: [env](case) remove disable pipeline engine case #57046 (#57109)
Cherry-picked from #57046
Co-authored-by: Mryange <[email protected]>
---
.../java/org/apache/doris/qe/SessionVariable.java | 35 ++-
.../data/correctness_p0/test_probe_clean.out | 6 -
.../load_p0/insert/test_insert_move_memtable.out | 29 --
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.out | 283 ------------------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.out | 59 ----
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.out | 10 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.out | 153 ----------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.out | 317 ---------------------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.out | 9 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.out | 3 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.out | 38 ---
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.out | 103 -------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.out | 205 -------------
.../data/ssb_sf0.1_p1/sql/pipelinex_q1.1.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q1.2.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q1.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q2.1.out | 43 ---
.../data/ssb_sf0.1_p1/sql/pipelinex_q2.2.out | 11 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q2.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.1.out | 28 --
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.2.out | 51 ----
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.4.out | 3 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q4.1.out | 8 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q4.2.out | 3 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q4.3.out | 3 -
.../cloud_p0/query_retry/test_retry_e-230.groovy | 1 -
...est_distinct_streaming_agg_local_shuffle.groovy | 3 -
.../correctness_p0/test_grouping_sets_empty.groovy | 5 -
.../suites/correctness_p0/test_probe_clean.groovy | 21 --
.../insert/test_insert_move_memtable.groovy | 119 --------
.../session_variable/test_default_limit.groovy | 8 +-
.../conditional_functions/test_nullif.groovy | 10 +-
.../query_p0/join/test_join_result_count.groovy | 3 -
.../join/test_partitioned_hash_join.groovy | 2 +-
.../schema_table/test_active_queries.groovy | 15 -
.../schema_table/test_backend_active_tasks.groovy | 15 -
.../session_variable/test_default_limit.groovy | 8 +-
.../array_functions/test_array_map_function.groovy | 8 -
.../bitmap_functions/test_bitmap_function.groovy | 26 --
.../conditional_functions/test_nullif.groovy | 10 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql | 24 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql | 24 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql | 25 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql | 24 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql | 27 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql | 26 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql | 27 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql | 33 ---
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql | 29 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql | 24 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql | 24 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql | 25 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql | 26 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql | 27 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql | 26 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql | 28 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql | 28 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql | 30 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql | 30 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql | 30 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql | 31 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql | 29 --
regression-test/suites/variant_p0/nested.groovy | 2 +-
71 files changed, 47 insertions(+), 2354 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
index 80af0119197..bcab9dbea77 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
@@ -1337,10 +1337,11 @@ public class SessionVariable implements Serializable,
Writable {
public boolean enableVectorizedEngine = true;
@VariableMgr.VarAttr(name = ENABLE_PIPELINE_ENGINE, fuzzy = false,
needForward = true,
- varType = VariableAnnotation.REMOVED)
+ varType = VariableAnnotation.REMOVED, setter =
"setEnablePipelineEngine")
private boolean enablePipelineEngine = true;
- @VariableMgr.VarAttr(name = ENABLE_PIPELINE_X_ENGINE, fuzzy = false,
varType = VariableAnnotation.REMOVED)
+ @VariableMgr.VarAttr(name = ENABLE_PIPELINE_X_ENGINE, fuzzy = false,
varType = VariableAnnotation.REMOVED,
+ setter = "setEnablePipelineXEngine")
private boolean enablePipelineXEngine = true;
@VariableMgr.VarAttr(name = ENABLE_SHARED_SCAN, fuzzy = false, varType =
VariableAnnotation.EXPERIMENTAL,
@@ -3545,6 +3546,36 @@ public class SessionVariable implements Serializable,
Writable {
this.parallelPipelineTaskNum = val;
}
+ public void setEnablePipelineEngine(String value) throws Exception {
+ if (value.equalsIgnoreCase("ON")
+ || value.equalsIgnoreCase("TRUE")
+ || value.equalsIgnoreCase("1")) {
+ this.enablePipelineEngine = true;
+ } else if (value.equalsIgnoreCase("OFF")
+ || value.equalsIgnoreCase("FALSE")
+ || value.equalsIgnoreCase("0")) {
+ throw new Exception(
+ "You cannot disable pipeline engine, because it is the
only execution engine now.");
+ } else {
+ throw new IllegalAccessException(value + " can not be parsed to
boolean");
+ }
+ }
+
+ public void setEnablePipelineXEngine(String value) throws Exception {
+ if (value.equalsIgnoreCase("ON")
+ || value.equalsIgnoreCase("TRUE")
+ || value.equalsIgnoreCase("1")) {
+ this.enablePipelineXEngine = true;
+ } else if (value.equalsIgnoreCase("OFF")
+ || value.equalsIgnoreCase("FALSE")
+ || value.equalsIgnoreCase("0")) {
+ throw new Exception(
+ "You cannot disable pipeline engine, because it is the
only execution engine now.");
+ } else {
+ throw new IllegalAccessException(value + " can not be parsed to
boolean");
+ }
+ }
+
public void setFragmentInstanceNum(String value) {}
public void setOrcTinyStripeThresholdBytes(String value) throws Exception {
diff --git a/regression-test/data/correctness_p0/test_probe_clean.out
b/regression-test/data/correctness_p0/test_probe_clean.out
index 78ab5a2b890..3334da116eb 100644
--- a/regression-test/data/correctness_p0/test_probe_clean.out
+++ b/regression-test/data/correctness_p0/test_probe_clean.out
@@ -2,9 +2,3 @@
-- !select_pipelineX --
2020 -5.2
--- !select_pipeline --
-2020 -5.2
-
--- !select_non_pipeline --
-2020 -5.2
-
diff --git a/regression-test/data/load_p0/insert/test_insert_move_memtable.out
b/regression-test/data/load_p0/insert/test_insert_move_memtable.out
deleted file mode 100644
index 0ff345a2459..00000000000
--- a/regression-test/data/load_p0/insert/test_insert_move_memtable.out
+++ /dev/null
@@ -1,29 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !sql1 --
-false -2147483647 7 7
-false 103 9 16
-false 1002 2 18
-false 5014 5 23
-false 2147483647 8 31
-true -2147483647 4 4
-true 3021 1 15
-true 3021 10 15
-true 25699 6 21
-true 2147483647 3 24
-
--- !sql2 --
-false -2147483647 7 7
-false 103 9 16
-false 1002 2 18
-false 5014 5 23
-false 2147483647 8 31
-true -2147483647 4 4
-true 3021 1 15
-true 3021 10 15
-true 25699 6 21
-true 2147483647 3 24
-
--- !select --
-true 10 10000 10000000 92233720368547758
19223372036854775807 3.14159 hello world, today is 15/06/2023
2023-06-15 2023-06-15T16:10:15
-true 10 10000 10000000 92233720368547758
19223372036854775807 3.14159 hello world, today is 15/06/2023
2023-06-15 2023-06-15T16:10:15
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.out
deleted file mode 100644
index 37d436b4a00..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q1.1 --
-40408592843
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.out
deleted file mode 100644
index 20f66697a74..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q1.2 --
-9122707260
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.out
deleted file mode 100644
index 2f50bd4a503..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q1.3 --
-2458647398
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.out
deleted file mode 100644
index ec27ff6aab3..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.out
+++ /dev/null
@@ -1,283 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q2.1 --
-44020938 1992 MFGR#121
-61069019 1992 MFGR#1210
-98770796 1992 MFGR#1211
-55714017 1992 MFGR#1212
-30859869 1992 MFGR#1213
-7655070 1992 MFGR#1214
-24888208 1992 MFGR#1215
-23379772 1992 MFGR#1216
-56476383 1992 MFGR#1217
-57043338 1992 MFGR#1218
-32145078 1992 MFGR#1219
-99329461 1992 MFGR#122
-74527914 1992 MFGR#1220
-44999728 1992 MFGR#1221
-51232286 1992 MFGR#1222
-34310857 1992 MFGR#1223
-113795427 1992 MFGR#1224
-34206250 1992 MFGR#1225
-55651923 1992 MFGR#1226
-41734506 1992 MFGR#1227
-49250683 1992 MFGR#1228
-38872880 1992 MFGR#1229
-19513495 1992 MFGR#123
-30074382 1992 MFGR#1230
-36122196 1992 MFGR#1231
-45964173 1992 MFGR#1232
-55214909 1992 MFGR#1233
-64954836 1992 MFGR#1234
-49076192 1992 MFGR#1235
-72479136 1992 MFGR#1236
-45028882 1992 MFGR#1237
-58021772 1992 MFGR#1238
-32264994 1992 MFGR#1239
-44086292 1992 MFGR#124
-69438922 1992 MFGR#1240
-50915712 1992 MFGR#125
-54423227 1992 MFGR#126
-38517896 1992 MFGR#127
-40358571 1992 MFGR#128
-29673343 1992 MFGR#129
-16480856 1993 MFGR#121
-61526362 1993 MFGR#1210
-62269128 1993 MFGR#1211
-49135175 1993 MFGR#1212
-19363246 1993 MFGR#1213
-29026117 1993 MFGR#1214
-35637454 1993 MFGR#1215
-20647862 1993 MFGR#1216
-65123252 1993 MFGR#1217
-25352010 1993 MFGR#1218
-68564939 1993 MFGR#1219
-17042606 1993 MFGR#122
-61430989 1993 MFGR#1220
-26382572 1993 MFGR#1221
-60006256 1993 MFGR#1222
-42890945 1993 MFGR#1223
-59983138 1993 MFGR#1224
-58171358 1993 MFGR#1225
-108538569 1993 MFGR#1226
-46953139 1993 MFGR#1227
-50357127 1993 MFGR#1228
-31565836 1993 MFGR#1229
-38160720 1993 MFGR#123
-50151622 1993 MFGR#1230
-29327673 1993 MFGR#1231
-38503874 1993 MFGR#1232
-19778805 1993 MFGR#1233
-41858350 1993 MFGR#1234
-24051246 1993 MFGR#1235
-52361976 1993 MFGR#1236
-38500972 1993 MFGR#1237
-40361967 1993 MFGR#1238
-52043689 1993 MFGR#1239
-64673820 1993 MFGR#124
-93511363 1993 MFGR#1240
-31696482 1993 MFGR#125
-65480881 1993 MFGR#126
-60071054 1993 MFGR#127
-44611749 1993 MFGR#128
-56729947 1993 MFGR#129
-25080633 1994 MFGR#121
-44421057 1994 MFGR#1210
-80008319 1994 MFGR#1211
-103863339 1994 MFGR#1212
-54621314 1994 MFGR#1213
-15680735 1994 MFGR#1214
-54681430 1994 MFGR#1215
-43692857 1994 MFGR#1216
-49325094 1994 MFGR#1217
-73675432 1994 MFGR#1218
-49871984 1994 MFGR#1219
-21256963 1994 MFGR#122
-31955137 1994 MFGR#1220
-48453428 1994 MFGR#1221
-53874152 1994 MFGR#1222
-62865250 1994 MFGR#1223
-63595818 1994 MFGR#1224
-28152809 1994 MFGR#1225
-69659357 1994 MFGR#1226
-75096847 1994 MFGR#1227
-42757254 1994 MFGR#1228
-32327218 1994 MFGR#1229
-22888353 1994 MFGR#123
-41728518 1994 MFGR#1230
-19387027 1994 MFGR#1231
-52487222 1994 MFGR#1232
-35994313 1994 MFGR#1233
-60742116 1994 MFGR#1234
-45227060 1994 MFGR#1235
-59160212 1994 MFGR#1236
-54619957 1994 MFGR#1237
-47480957 1994 MFGR#1238
-25888685 1994 MFGR#1239
-70368638 1994 MFGR#124
-72629620 1994 MFGR#1240
-33238482 1994 MFGR#125
-72394492 1994 MFGR#126
-56029736 1994 MFGR#127
-38147992 1994 MFGR#128
-69501483 1994 MFGR#129
-20924289 1995 MFGR#121
-36975122 1995 MFGR#1210
-48756873 1995 MFGR#1211
-53856557 1995 MFGR#1212
-38371527 1995 MFGR#1213
-20160501 1995 MFGR#1214
-24921435 1995 MFGR#1215
-49182346 1995 MFGR#1216
-79421062 1995 MFGR#1217
-43871805 1995 MFGR#1218
-40799560 1995 MFGR#1219
-48863048 1995 MFGR#122
-30480350 1995 MFGR#1220
-39631840 1995 MFGR#1221
-46048864 1995 MFGR#1222
-54794320 1995 MFGR#1223
-58418860 1995 MFGR#1224
-46832764 1995 MFGR#1225
-93015568 1995 MFGR#1226
-59555495 1995 MFGR#1227
-64677848 1995 MFGR#1228
-54371856 1995 MFGR#1229
-41367445 1995 MFGR#123
-62730952 1995 MFGR#1230
-20240121 1995 MFGR#1231
-31312779 1995 MFGR#1232
-61254571 1995 MFGR#1233
-101408529 1995 MFGR#1234
-35489977 1995 MFGR#1235
-72283474 1995 MFGR#1236
-44169187 1995 MFGR#1237
-76982851 1995 MFGR#1238
-17887986 1995 MFGR#1239
-25579008 1995 MFGR#124
-57259273 1995 MFGR#1240
-48737579 1995 MFGR#125
-46441183 1995 MFGR#126
-78098863 1995 MFGR#127
-27870848 1995 MFGR#128
-35908546 1995 MFGR#129
-35271098 1996 MFGR#121
-38792230 1996 MFGR#1210
-47160693 1996 MFGR#1211
-68210595 1996 MFGR#1212
-44722895 1996 MFGR#1213
-26593762 1996 MFGR#1214
-32215205 1996 MFGR#1215
-36462712 1996 MFGR#1216
-74558576 1996 MFGR#1217
-54779933 1996 MFGR#1218
-73411970 1996 MFGR#1219
-34964197 1996 MFGR#122
-68558799 1996 MFGR#1220
-51301494 1996 MFGR#1221
-72933737 1996 MFGR#1222
-63554793 1996 MFGR#1223
-89879873 1996 MFGR#1224
-66262314 1996 MFGR#1225
-80568026 1996 MFGR#1226
-44565937 1996 MFGR#1227
-52846872 1996 MFGR#1228
-44976411 1996 MFGR#1229
-15588645 1996 MFGR#123
-53581284 1996 MFGR#1230
-22553880 1996 MFGR#1231
-96176719 1996 MFGR#1232
-52077897 1996 MFGR#1233
-66828307 1996 MFGR#1234
-30327368 1996 MFGR#1235
-50040478 1996 MFGR#1236
-46199045 1996 MFGR#1237
-40764060 1996 MFGR#1238
-60654980 1996 MFGR#1239
-69640803 1996 MFGR#124
-48177264 1996 MFGR#1240
-28190715 1996 MFGR#125
-50400382 1996 MFGR#126
-64695119 1996 MFGR#127
-56829515 1996 MFGR#128
-34826763 1996 MFGR#129
-22963752 1997 MFGR#121
-34840658 1997 MFGR#1210
-49126086 1997 MFGR#1211
-68574455 1997 MFGR#1212
-38647328 1997 MFGR#1213
-19070678 1997 MFGR#1214
-34729724 1997 MFGR#1215
-45360726 1997 MFGR#1216
-100366087 1997 MFGR#1217
-23839879 1997 MFGR#1218
-64452428 1997 MFGR#1219
-29119805 1997 MFGR#122
-49517616 1997 MFGR#1220
-69279406 1997 MFGR#1221
-56714590 1997 MFGR#1222
-39678871 1997 MFGR#1223
-73858672 1997 MFGR#1224
-13942407 1997 MFGR#1225
-80693293 1997 MFGR#1226
-79034646 1997 MFGR#1227
-60410183 1997 MFGR#1228
-29923476 1997 MFGR#1229
-38002024 1997 MFGR#123
-15398954 1997 MFGR#1230
-25870965 1997 MFGR#1231
-82101226 1997 MFGR#1232
-35715749 1997 MFGR#1233
-47016892 1997 MFGR#1234
-60104390 1997 MFGR#1235
-49230267 1997 MFGR#1236
-60826887 1997 MFGR#1237
-46058415 1997 MFGR#1238
-20840231 1997 MFGR#1239
-73636093 1997 MFGR#124
-52792905 1997 MFGR#1240
-49503830 1997 MFGR#125
-40570441 1997 MFGR#126
-52426752 1997 MFGR#127
-56182164 1997 MFGR#128
-37727233 1997 MFGR#129
-3549137 1998 MFGR#121
-49830740 1998 MFGR#1210
-20393668 1998 MFGR#1211
-21173543 1998 MFGR#1212
-20087827 1998 MFGR#1213
-10743126 1998 MFGR#1214
-12847957 1998 MFGR#1215
-19691011 1998 MFGR#1216
-51049704 1998 MFGR#1217
-23558548 1998 MFGR#1218
-25951054 1998 MFGR#1219
-17166766 1998 MFGR#122
-28493696 1998 MFGR#1220
-12744431 1998 MFGR#1221
-22077936 1998 MFGR#1222
-33163504 1998 MFGR#1223
-66412310 1998 MFGR#1224
-26213544 1998 MFGR#1225
-32389442 1998 MFGR#1226
-42104295 1998 MFGR#1227
-33078210 1998 MFGR#1228
-37064611 1998 MFGR#1229
-24156825 1998 MFGR#123
-25580571 1998 MFGR#1230
-10782317 1998 MFGR#1231
-22813148 1998 MFGR#1232
-17629146 1998 MFGR#1233
-36569860 1998 MFGR#1234
-40382918 1998 MFGR#1235
-35602723 1998 MFGR#1236
-24130345 1998 MFGR#1237
-30693015 1998 MFGR#1238
-14929431 1998 MFGR#1239
-39975811 1998 MFGR#124
-16736766 1998 MFGR#1240
-29646784 1998 MFGR#125
-19901786 1998 MFGR#126
-45106934 1998 MFGR#127
-26254536 1998 MFGR#128
-42825370 1998 MFGR#129
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.out
deleted file mode 100644
index 185d2691f6f..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.out
+++ /dev/null
@@ -1,59 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q2.2 --
-49901521 1992 MFGR#2221
-96163939 1992 MFGR#2222
-90215446 1992 MFGR#2223
-48493609 1992 MFGR#2224
-110952177 1992 MFGR#2225
-106008540 1992 MFGR#2226
-57647604 1992 MFGR#2227
-86072957 1992 MFGR#2228
-67725886 1993 MFGR#2221
-67725009 1993 MFGR#2222
-81806477 1993 MFGR#2223
-50421651 1993 MFGR#2224
-94454058 1993 MFGR#2225
-70629830 1993 MFGR#2226
-45404279 1993 MFGR#2227
-79310904 1993 MFGR#2228
-47777086 1994 MFGR#2221
-71637360 1994 MFGR#2222
-72156568 1994 MFGR#2223
-51587753 1994 MFGR#2224
-83364340 1994 MFGR#2225
-60478099 1994 MFGR#2226
-56003454 1994 MFGR#2227
-89029764 1994 MFGR#2228
-72175190 1995 MFGR#2221
-71019982 1995 MFGR#2222
-96319277 1995 MFGR#2223
-68803330 1995 MFGR#2224
-80093694 1995 MFGR#2225
-78383156 1995 MFGR#2226
-49502866 1995 MFGR#2227
-104551526 1995 MFGR#2228
-51297584 1996 MFGR#2221
-96580568 1996 MFGR#2222
-75725909 1996 MFGR#2223
-64823360 1996 MFGR#2224
-125578266 1996 MFGR#2225
-47938897 1996 MFGR#2226
-70423501 1996 MFGR#2227
-108054309 1996 MFGR#2228
-108073280 1997 MFGR#2221
-43179221 1997 MFGR#2222
-70814037 1997 MFGR#2223
-60936293 1997 MFGR#2224
-81810165 1997 MFGR#2225
-67439343 1997 MFGR#2226
-42064594 1997 MFGR#2227
-87179304 1997 MFGR#2228
-25132568 1998 MFGR#2221
-55722350 1998 MFGR#2222
-48431542 1998 MFGR#2223
-12880429 1998 MFGR#2224
-32016105 1998 MFGR#2225
-39867983 1998 MFGR#2226
-17482648 1998 MFGR#2227
-54980480 1998 MFGR#2228
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.out
deleted file mode 100644
index f0c83b7b043..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.out
+++ /dev/null
@@ -1,10 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q2.3 --
-126104513 1992 MFGR#2239
-55041640 1993 MFGR#2239
-53176975 1994 MFGR#2239
-91516581 1995 MFGR#2239
-89177504 1996 MFGR#2239
-109557743 1997 MFGR#2239
-64474863 1998 MFGR#2239
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.out
deleted file mode 100644
index 64a9bb16e94..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.out
+++ /dev/null
@@ -1,153 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q3.1 --
-JAPAN CHINA 1992 894662617
-VIETNAM CHINA 1992 879657868
-INDONESIA CHINA 1992 848560058
-CHINA CHINA 1992 819815922
-INDIA CHINA 1992 806291092
-JAPAN INDONESIA 1992 680053883
-VIETNAM INDONESIA 1992 673179581
-INDONESIA INDONESIA 1992 664270844
-INDONESIA JAPAN 1992 643752974
-INDIA INDONESIA 1992 638903445
-JAPAN VIETNAM 1992 635824950
-JAPAN JAPAN 1992 633585481
-INDIA JAPAN 1992 607839613
-VIETNAM JAPAN 1992 607710783
-INDIA INDIA 1992 536769929
-JAPAN INDIA 1992 534088599
-VIETNAM VIETNAM 1992 516117221
-CHINA INDONESIA 1992 506456790
-CHINA INDIA 1992 480846807
-CHINA VIETNAM 1992 477208003
-CHINA JAPAN 1992 472412008
-INDIA VIETNAM 1992 471237542
-INDONESIA VIETNAM 1992 459553516
-VIETNAM INDIA 1992 456110182
-INDONESIA INDIA 1992 455186775
-INDONESIA CHINA 1993 943734711
-JAPAN CHINA 1993 884999330
-VIETNAM CHINA 1993 776170628
-JAPAN JAPAN 1993 763155805
-INDIA CHINA 1993 727268159
-JAPAN INDONESIA 1993 725974841
-CHINA CHINA 1993 699037918
-VIETNAM INDONESIA 1993 678558585
-INDIA INDONESIA 1993 636586282
-JAPAN VIETNAM 1993 615519995
-CHINA INDONESIA 1993 611808285
-INDONESIA INDONESIA 1993 603487543
-VIETNAM JAPAN 1993 581395052
-INDIA INDIA 1993 562950799
-VIETNAM INDIA 1993 560138093
-JAPAN INDIA 1993 556451843
-INDONESIA JAPAN 1993 551536311
-INDIA JAPAN 1993 520291875
-INDONESIA VIETNAM 1993 516700032
-CHINA JAPAN 1993 513860361
-VIETNAM VIETNAM 1993 511572341
-INDONESIA INDIA 1993 475772900
-CHINA INDIA 1993 469387738
-CHINA VIETNAM 1993 445157921
-INDIA VIETNAM 1993 421899314
-JAPAN CHINA 1994 1078430520
-CHINA CHINA 1994 780416580
-INDIA CHINA 1994 775588173
-VIETNAM CHINA 1994 770264574
-JAPAN JAPAN 1994 759994553
-JAPAN INDONESIA 1994 714753599
-INDONESIA CHINA 1994 714095689
-VIETNAM JAPAN 1994 709054030
-INDONESIA JAPAN 1994 700405590
-VIETNAM VIETNAM 1994 642825294
-INDONESIA INDONESIA 1994 620705729
-JAPAN INDIA 1994 615711853
-JAPAN VIETNAM 1994 604773981
-INDIA JAPAN 1994 603556186
-INDONESIA VIETNAM 1994 583034876
-VIETNAM INDONESIA 1994 564257510
-INDIA INDONESIA 1994 516996319
-VIETNAM INDIA 1994 499086392
-CHINA JAPAN 1994 497106086
-CHINA INDONESIA 1994 464805234
-INDIA INDIA 1994 460482523
-INDIA VIETNAM 1994 457376149
-INDONESIA INDIA 1994 456297959
-CHINA INDIA 1994 432006728
-CHINA VIETNAM 1994 351960554
-JAPAN CHINA 1995 986663348
-INDIA CHINA 1995 861068631
-INDONESIA CHINA 1995 822855656
-CHINA CHINA 1995 767174809
-JAPAN INDONESIA 1995 745662666
-VIETNAM CHINA 1995 729675158
-JAPAN JAPAN 1995 707259778
-VIETNAM JAPAN 1995 692786366
-INDONESIA JAPAN 1995 691858407
-INDONESIA INDONESIA 1995 643912652
-VIETNAM INDONESIA 1995 623670464
-JAPAN VIETNAM 1995 595667658
-INDIA JAPAN 1995 595328992
-INDONESIA INDIA 1995 578833336
-INDIA VIETNAM 1995 575485335
-CHINA JAPAN 1995 574277531
-INDIA INDONESIA 1995 573908169
-CHINA INDONESIA 1995 545491112
-VIETNAM INDIA 1995 539065793
-JAPAN INDIA 1995 535604852
-VIETNAM VIETNAM 1995 533647175
-INDIA INDIA 1995 479262711
-INDONESIA VIETNAM 1995 467482484
-CHINA VIETNAM 1995 456995300
-CHINA INDIA 1995 428711969
-JAPAN CHINA 1996 986140813
-VIETNAM CHINA 1996 802903887
-JAPAN JAPAN 1996 770237433
-JAPAN INDONESIA 1996 753998482
-INDONESIA CHINA 1996 740555766
-CHINA CHINA 1996 725619149
-CHINA INDONESIA 1996 679336367
-INDIA CHINA 1996 671074957
-VIETNAM JAPAN 1996 644535010
-VIETNAM INDONESIA 1996 641798202
-JAPAN INDIA 1996 617455416
-INDONESIA JAPAN 1996 615961620
-JAPAN VIETNAM 1996 615247275
-CHINA JAPAN 1996 567641014
-INDIA INDONESIA 1996 553269889
-INDIA JAPAN 1996 529524803
-INDONESIA INDONESIA 1996 522610713
-VIETNAM VIETNAM 1996 492513335
-CHINA INDIA 1996 485501126
-VIETNAM INDIA 1996 483604465
-INDIA VIETNAM 1996 476602949
-INDONESIA INDIA 1996 459775845
-INDONESIA VIETNAM 1996 436568261
-CHINA VIETNAM 1996 427435930
-INDIA INDIA 1996 378608488
-JAPAN CHINA 1997 950779597
-VIETNAM CHINA 1997 908837192
-INDONESIA CHINA 1997 869538220
-INDIA CHINA 1997 798545421
-JAPAN INDONESIA 1997 793631604
-JAPAN JAPAN 1997 743977084
-VIETNAM JAPAN 1997 662366183
-VIETNAM INDONESIA 1997 656632582
-INDIA INDONESIA 1997 644452063
-CHINA CHINA 1997 638308872
-INDONESIA JAPAN 1997 601147475
-INDIA JAPAN 1997 591931506
-CHINA INDONESIA 1997 588058561
-JAPAN INDIA 1997 586235315
-INDONESIA INDIA 1997 580061411
-CHINA JAPAN 1997 576981874
-INDONESIA INDONESIA 1997 570813647
-JAPAN VIETNAM 1997 560180609
-INDIA VIETNAM 1997 537809881
-VIETNAM INDIA 1997 509338268
-INDONESIA VIETNAM 1997 506305004
-VIETNAM VIETNAM 1997 480669507
-CHINA INDIA 1997 465641614
-CHINA VIETNAM 1997 453346071
-INDIA INDIA 1997 384517066
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.out
deleted file mode 100644
index d7f97e47891..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.out
+++ /dev/null
@@ -1,317 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q3.2 --
-UNITED ST4 UNITED ST0 1992 41731025
-UNITED ST4 UNITED ST3 1992 40001969
-UNITED ST1 UNITED ST9 1992 33158800
-UNITED ST4 UNITED ST9 1992 28893071
-UNITED ST2 UNITED ST0 1992 28495669
-UNITED ST4 UNITED ST6 1992 24351778
-UNITED ST2 UNITED ST3 1992 23948087
-UNITED ST7 UNITED ST3 1992 23105112
-UNITED ST1 UNITED ST0 1992 22259691
-UNITED ST1 UNITED ST7 1992 22081488
-UNITED ST0 UNITED ST0 1992 18293852
-UNITED ST1 UNITED ST3 1992 18119462
-UNITED ST9 UNITED ST3 1992 17863433
-UNITED ST5 UNITED ST6 1992 17493829
-UNITED ST5 UNITED ST2 1992 17414941
-UNITED ST7 UNITED ST9 1992 17042156
-UNITED ST4 UNITED ST2 1992 16123916
-UNITED ST9 UNITED ST0 1992 15335446
-UNITED ST5 UNITED ST9 1992 14871338
-UNITED ST6 UNITED ST0 1992 14409189
-UNITED ST4 UNITED ST7 1992 13420748
-UNITED ST8 UNITED ST0 1992 12694771
-UNITED ST1 UNITED ST6 1992 12615015
-UNITED ST5 UNITED ST3 1992 12609431
-UNITED ST9 UNITED ST2 1992 12370917
-UNITED ST2 UNITED ST9 1992 12343455
-UNITED ST5 UNITED ST0 1992 12301234
-UNITED ST0 UNITED ST3 1992 11998215
-UNITED ST0 UNITED ST7 1992 11561727
-UNITED ST0 UNITED ST9 1992 10044917
-UNITED ST1 UNITED ST2 1992 9911709
-UNITED ST7 UNITED ST7 1992 9715656
-UNITED ST8 UNITED ST9 1992 9595969
-UNITED ST9 UNITED ST9 1992 9263093
-UNITED ST7 UNITED ST2 1992 9032051
-UNITED ST6 UNITED ST6 1992 8685228
-UNITED ST2 UNITED ST2 1992 8313714
-UNITED ST2 UNITED ST7 1992 7759164
-UNITED ST7 UNITED ST0 1992 7492111
-UNITED ST5 UNITED ST7 1992 7225053
-UNITED ST9 UNITED ST7 1992 7204874
-UNITED ST6 UNITED ST9 1992 6597261
-UNITED ST7 UNITED ST6 1992 6058017
-UNITED ST8 UNITED ST7 1992 5480207
-UNITED ST3 UNITED ST3 1992 4080199
-UNITED ST2 UNITED ST6 1992 2888270
-UNITED ST3 UNITED ST9 1992 2614811
-UNITED ST9 UNITED ST6 1992 2066609
-UNITED ST6 UNITED ST3 1992 1873819
-UNITED ST0 UNITED ST2 1992 742480
-UNITED ST6 UNITED ST2 1992 291566
-UNITED ST4 UNITED ST3 1993 40655188
-UNITED ST2 UNITED ST3 1993 36003298
-UNITED ST5 UNITED ST3 1993 35074448
-UNITED ST1 UNITED ST0 1993 32371096
-UNITED ST7 UNITED ST0 1993 31623473
-UNITED ST1 UNITED ST9 1993 26085806
-UNITED ST4 UNITED ST7 1993 21770572
-UNITED ST5 UNITED ST0 1993 21615102
-UNITED ST7 UNITED ST6 1993 21431650
-UNITED ST5 UNITED ST9 1993 20060148
-UNITED ST1 UNITED ST3 1993 19637560
-UNITED ST7 UNITED ST9 1993 19210567
-UNITED ST4 UNITED ST9 1993 18760567
-UNITED ST0 UNITED ST0 1993 17492841
-UNITED ST7 UNITED ST3 1993 15593304
-UNITED ST4 UNITED ST0 1993 15352086
-UNITED ST5 UNITED ST7 1993 14364086
-UNITED ST9 UNITED ST3 1993 14042622
-UNITED ST9 UNITED ST6 1993 13589827
-UNITED ST9 UNITED ST0 1993 12719524
-UNITED ST2 UNITED ST9 1993 11922413
-UNITED ST6 UNITED ST6 1993 11516451
-UNITED ST4 UNITED ST2 1993 11384511
-UNITED ST3 UNITED ST3 1993 11191859
-UNITED ST3 UNITED ST0 1993 9854232
-UNITED ST6 UNITED ST3 1993 9745502
-UNITED ST2 UNITED ST2 1993 9293748
-UNITED ST1 UNITED ST6 1993 8167490
-UNITED ST8 UNITED ST9 1993 7538212
-UNITED ST0 UNITED ST9 1993 7051950
-UNITED ST0 UNITED ST3 1993 7048726
-UNITED ST9 UNITED ST2 1993 6542474
-UNITED ST5 UNITED ST6 1993 6445893
-UNITED ST1 UNITED ST2 1993 6218710
-UNITED ST9 UNITED ST9 1993 5718455
-UNITED ST1 UNITED ST7 1993 5301113
-UNITED ST2 UNITED ST0 1993 5272433
-UNITED ST8 UNITED ST0 1993 5183529
-UNITED ST5 UNITED ST2 1993 5154059
-UNITED ST6 UNITED ST9 1993 4893382
-UNITED ST8 UNITED ST3 1993 4251663
-UNITED ST3 UNITED ST9 1993 3950878
-UNITED ST6 UNITED ST2 1993 3713458
-UNITED ST8 UNITED ST7 1993 3584217
-UNITED ST6 UNITED ST7 1993 3449550
-UNITED ST3 UNITED ST7 1993 3028547
-UNITED ST0 UNITED ST2 1993 2972456
-UNITED ST7 UNITED ST2 1993 2849011
-UNITED ST2 UNITED ST6 1993 2026185
-UNITED ST0 UNITED ST7 1993 1920827
-UNITED ST8 UNITED ST6 1993 1728360
-UNITED ST4 UNITED ST6 1993 1327362
-UNITED ST7 UNITED ST7 1993 1259361
-UNITED ST8 UNITED ST2 1993 1205222
-UNITED ST2 UNITED ST7 1993 861413
-UNITED ST0 UNITED ST6 1993 239766
-UNITED ST4 UNITED ST3 1994 56786075
-UNITED ST2 UNITED ST0 1994 39867652
-UNITED ST1 UNITED ST9 1994 36849068
-UNITED ST7 UNITED ST3 1994 36135207
-UNITED ST1 UNITED ST0 1994 34629122
-UNITED ST5 UNITED ST0 1994 33907176
-UNITED ST5 UNITED ST9 1994 33823060
-UNITED ST4 UNITED ST0 1994 31296783
-UNITED ST2 UNITED ST3 1994 30499072
-UNITED ST1 UNITED ST3 1994 24377956
-UNITED ST7 UNITED ST0 1994 23008324
-UNITED ST2 UNITED ST9 1994 21959692
-UNITED ST2 UNITED ST7 1994 20638024
-UNITED ST2 UNITED ST6 1994 20528502
-UNITED ST9 UNITED ST3 1994 18885838
-UNITED ST0 UNITED ST3 1994 17087910
-UNITED ST5 UNITED ST3 1994 15657670
-UNITED ST9 UNITED ST0 1994 15346708
-UNITED ST0 UNITED ST9 1994 15287365
-UNITED ST1 UNITED ST7 1994 14942235
-UNITED ST7 UNITED ST9 1994 14832404
-UNITED ST5 UNITED ST2 1994 14684226
-UNITED ST0 UNITED ST0 1994 14402583
-UNITED ST1 UNITED ST6 1994 13845158
-UNITED ST5 UNITED ST6 1994 13062098
-UNITED ST9 UNITED ST7 1994 12190876
-UNITED ST7 UNITED ST2 1994 11794166
-UNITED ST4 UNITED ST9 1994 10839580
-UNITED ST6 UNITED ST6 1994 10539775
-UNITED ST8 UNITED ST3 1994 10521895
-UNITED ST3 UNITED ST3 1994 8638496
-UNITED ST9 UNITED ST6 1994 7446705
-UNITED ST6 UNITED ST0 1994 7185704
-UNITED ST4 UNITED ST7 1994 7128172
-UNITED ST4 UNITED ST2 1994 6706172
-UNITED ST6 UNITED ST9 1994 5203336
-UNITED ST6 UNITED ST3 1994 5073736
-UNITED ST6 UNITED ST7 1994 4976821
-UNITED ST1 UNITED ST2 1994 4941099
-UNITED ST0 UNITED ST7 1994 4844537
-UNITED ST0 UNITED ST6 1994 4830134
-UNITED ST0 UNITED ST2 1994 4733405
-UNITED ST3 UNITED ST0 1994 4537669
-UNITED ST9 UNITED ST9 1994 4529452
-UNITED ST7 UNITED ST6 1994 4075826
-UNITED ST8 UNITED ST6 1994 3931144
-UNITED ST2 UNITED ST2 1994 3459349
-UNITED ST3 UNITED ST6 1994 3431309
-UNITED ST8 UNITED ST0 1994 1741475
-UNITED ST3 UNITED ST9 1994 1523937
-UNITED ST7 UNITED ST7 1994 1431045
-UNITED ST8 UNITED ST2 1994 1128443
-UNITED ST2 UNITED ST9 1995 36282710
-UNITED ST2 UNITED ST3 1995 35484180
-UNITED ST7 UNITED ST9 1995 29730468
-UNITED ST1 UNITED ST3 1995 27630044
-UNITED ST7 UNITED ST3 1995 27429744
-UNITED ST4 UNITED ST3 1995 27071122
-UNITED ST5 UNITED ST3 1995 26581069
-UNITED ST4 UNITED ST6 1995 25783319
-UNITED ST5 UNITED ST0 1995 24869803
-UNITED ST0 UNITED ST0 1995 24489125
-UNITED ST9 UNITED ST0 1995 22146600
-UNITED ST4 UNITED ST0 1995 21413592
-UNITED ST9 UNITED ST9 1995 21288680
-UNITED ST5 UNITED ST9 1995 20601949
-UNITED ST1 UNITED ST6 1995 18131457
-UNITED ST1 UNITED ST0 1995 17183088
-UNITED ST4 UNITED ST9 1995 17064057
-UNITED ST2 UNITED ST0 1995 17061868
-UNITED ST1 UNITED ST9 1995 16559901
-UNITED ST0 UNITED ST9 1995 15255164
-UNITED ST9 UNITED ST3 1995 14519986
-UNITED ST0 UNITED ST3 1995 14085981
-UNITED ST7 UNITED ST0 1995 12686420
-UNITED ST2 UNITED ST6 1995 12238732
-UNITED ST9 UNITED ST6 1995 12092801
-UNITED ST7 UNITED ST6 1995 11244631
-UNITED ST6 UNITED ST0 1995 9285442
-UNITED ST6 UNITED ST2 1995 8987771
-UNITED ST5 UNITED ST7 1995 8841032
-UNITED ST8 UNITED ST3 1995 8767451
-UNITED ST7 UNITED ST7 1995 8726612
-UNITED ST3 UNITED ST6 1995 8520722
-UNITED ST6 UNITED ST3 1995 7711813
-UNITED ST2 UNITED ST7 1995 7275705
-UNITED ST0 UNITED ST6 1995 6314215
-UNITED ST9 UNITED ST2 1995 6173678
-UNITED ST3 UNITED ST9 1995 5823913
-UNITED ST1 UNITED ST2 1995 5797623
-UNITED ST4 UNITED ST2 1995 5343777
-UNITED ST8 UNITED ST0 1995 4872186
-UNITED ST7 UNITED ST2 1995 4793054
-UNITED ST3 UNITED ST3 1995 4757898
-UNITED ST5 UNITED ST2 1995 4727810
-UNITED ST6 UNITED ST9 1995 4323440
-UNITED ST5 UNITED ST6 1995 4074166
-UNITED ST1 UNITED ST7 1995 3766151
-UNITED ST3 UNITED ST0 1995 3227817
-UNITED ST9 UNITED ST7 1995 1755678
-UNITED ST8 UNITED ST9 1995 580117
-UNITED ST6 UNITED ST7 1995 121961
-UNITED ST7 UNITED ST0 1996 43046117
-UNITED ST4 UNITED ST3 1996 31999863
-UNITED ST1 UNITED ST3 1996 31649828
-UNITED ST2 UNITED ST3 1996 29871031
-UNITED ST5 UNITED ST3 1996 29177422
-UNITED ST7 UNITED ST3 1996 26823399
-UNITED ST2 UNITED ST0 1996 24571005
-UNITED ST4 UNITED ST6 1996 23629745
-UNITED ST7 UNITED ST6 1996 22124325
-UNITED ST2 UNITED ST9 1996 20665225
-UNITED ST5 UNITED ST7 1996 19002925
-UNITED ST9 UNITED ST3 1996 18625572
-UNITED ST9 UNITED ST0 1996 16972322
-UNITED ST4 UNITED ST0 1996 16605828
-UNITED ST4 UNITED ST9 1996 15641240
-UNITED ST1 UNITED ST9 1996 14655108
-UNITED ST7 UNITED ST7 1996 14200242
-UNITED ST9 UNITED ST6 1996 13464987
-UNITED ST3 UNITED ST9 1996 12451358
-UNITED ST6 UNITED ST2 1996 12362074
-UNITED ST0 UNITED ST2 1996 12275126
-UNITED ST0 UNITED ST3 1996 11826143
-UNITED ST2 UNITED ST6 1996 11455069
-UNITED ST5 UNITED ST9 1996 11383869
-UNITED ST0 UNITED ST0 1996 11296453
-UNITED ST6 UNITED ST9 1996 10757396
-UNITED ST3 UNITED ST3 1996 10513276
-UNITED ST0 UNITED ST9 1996 10147365
-UNITED ST1 UNITED ST2 1996 9773797
-UNITED ST9 UNITED ST2 1996 9438435
-UNITED ST6 UNITED ST3 1996 9342044
-UNITED ST8 UNITED ST9 1996 9247187
-UNITED ST1 UNITED ST7 1996 9042320
-UNITED ST7 UNITED ST9 1996 9013568
-UNITED ST9 UNITED ST9 1996 8980638
-UNITED ST5 UNITED ST0 1996 8552217
-UNITED ST6 UNITED ST7 1996 8221347
-UNITED ST9 UNITED ST7 1996 8210248
-UNITED ST2 UNITED ST2 1996 8125332
-UNITED ST1 UNITED ST0 1996 7469781
-UNITED ST4 UNITED ST2 1996 7050699
-UNITED ST5 UNITED ST2 1996 6684834
-UNITED ST0 UNITED ST7 1996 6169927
-UNITED ST3 UNITED ST0 1996 5411275
-UNITED ST3 UNITED ST6 1996 5129866
-UNITED ST6 UNITED ST0 1996 5012896
-UNITED ST7 UNITED ST2 1996 4949885
-UNITED ST1 UNITED ST6 1996 4432387
-UNITED ST2 UNITED ST7 1996 3802080
-UNITED ST8 UNITED ST2 1996 2813925
-UNITED ST6 UNITED ST6 1996 2796195
-UNITED ST3 UNITED ST7 1996 2723812
-UNITED ST8 UNITED ST6 1996 1604698
-UNITED ST4 UNITED ST7 1996 872339
-UNITED ST4 UNITED ST3 1997 41543013
-UNITED ST7 UNITED ST3 1997 38517527
-UNITED ST7 UNITED ST7 1997 35180248
-UNITED ST1 UNITED ST3 1997 29038386
-UNITED ST2 UNITED ST0 1997 28725513
-UNITED ST5 UNITED ST3 1997 27261467
-UNITED ST8 UNITED ST9 1997 22351756
-UNITED ST1 UNITED ST0 1997 21810980
-UNITED ST5 UNITED ST9 1997 20049570
-UNITED ST0 UNITED ST7 1997 19895765
-UNITED ST2 UNITED ST3 1997 18172167
-UNITED ST5 UNITED ST6 1997 18137063
-UNITED ST5 UNITED ST0 1997 17044142
-UNITED ST0 UNITED ST6 1997 16771333
-UNITED ST0 UNITED ST0 1997 16726896
-UNITED ST4 UNITED ST2 1997 16381337
-UNITED ST2 UNITED ST7 1997 15974714
-UNITED ST1 UNITED ST6 1997 14935124
-UNITED ST4 UNITED ST9 1997 14177148
-UNITED ST1 UNITED ST9 1997 13785007
-UNITED ST6 UNITED ST6 1997 13513362
-UNITED ST4 UNITED ST6 1997 13374220
-UNITED ST9 UNITED ST3 1997 13095174
-UNITED ST7 UNITED ST6 1997 11572813
-UNITED ST9 UNITED ST9 1997 11569028
-UNITED ST6 UNITED ST0 1997 11320722
-UNITED ST2 UNITED ST2 1997 10427890
-UNITED ST0 UNITED ST3 1997 10077913
-UNITED ST7 UNITED ST0 1997 8617843
-UNITED ST6 UNITED ST2 1997 7774767
-UNITED ST6 UNITED ST7 1997 7772982
-UNITED ST1 UNITED ST2 1997 7540067
-UNITED ST2 UNITED ST6 1997 7482323
-UNITED ST7 UNITED ST9 1997 7464182
-UNITED ST4 UNITED ST0 1997 7381500
-UNITED ST6 UNITED ST3 1997 7378889
-UNITED ST4 UNITED ST7 1997 7314217
-UNITED ST1 UNITED ST7 1997 7002722
-UNITED ST8 UNITED ST3 1997 6618773
-UNITED ST3 UNITED ST0 1997 4915297
-UNITED ST2 UNITED ST9 1997 4357257
-UNITED ST6 UNITED ST9 1997 3566068
-UNITED ST9 UNITED ST0 1997 3120773
-UNITED ST3 UNITED ST7 1997 3003109
-UNITED ST7 UNITED ST2 1997 2965713
-UNITED ST0 UNITED ST9 1997 2775552
-UNITED ST3 UNITED ST3 1997 2480732
-UNITED ST9 UNITED ST7 1997 1683427
-UNITED ST8 UNITED ST2 1997 1055237
-UNITED ST5 UNITED ST2 1997 520484
-UNITED ST9 UNITED ST2 1997 281577
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.out
deleted file mode 100644
index 572d55e018e..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.out
+++ /dev/null
@@ -1,9 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q3.3 --
-UNITED KI5 UNITED KI1 1992 4397192
-UNITED KI5 UNITED KI1 1993 7269877
-UNITED KI1 UNITED KI1 1993 1243929
-UNITED KI1 UNITED KI1 1995 7942813
-UNITED KI5 UNITED KI1 1995 7117276
-UNITED KI5 UNITED KI1 1996 5994601
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.out
deleted file mode 100644
index 82b645f3930..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.out
+++ /dev/null
@@ -1,3 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q3.4 --
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.out
deleted file mode 100644
index 280c24417d8..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.out
+++ /dev/null
@@ -1,38 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q4.1 --
-1992 ARGENTINA 761138275
-1992 BRAZIL 985977209
-1992 CANADA 715150888
-1992 PERU 786152296
-1992 UNITED STATES 907927557
-1993 ARGENTINA 784246323
-1993 BRAZIL 795928807
-1993 CANADA 799906352
-1993 PERU 662883880
-1993 UNITED STATES 839069702
-1994 ARGENTINA 876750011
-1994 BRAZIL 812474812
-1994 CANADA 869964593
-1994 PERU 747762673
-1994 UNITED STATES 976192749
-1995 ARGENTINA 759176421
-1995 BRAZIL 801672129
-1995 CANADA 839133378
-1995 PERU 824927582
-1995 UNITED STATES 834105034
-1996 ARGENTINA 694255805
-1996 BRAZIL 881917583
-1996 CANADA 837622649
-1996 PERU 679125115
-1996 UNITED STATES 813543116
-1997 ARGENTINA 757821503
-1997 BRAZIL 680132381
-1997 CANADA 867432100
-1997 PERU 786577542
-1997 UNITED STATES 814894451
-1998 ARGENTINA 368756023
-1998 BRAZIL 560248513
-1998 CANADA 455229134
-1998 PERU 436261212
-1998 UNITED STATES 387112795
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.out
deleted file mode 100644
index fbbf86b4802..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.out
+++ /dev/null
@@ -1,103 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q4.2 --
-1997 ARGENTINA MFGR#11 84900777
-1997 ARGENTINA MFGR#12 105777008
-1997 ARGENTINA MFGR#13 64922663
-1997 ARGENTINA MFGR#14 74698017
-1997 ARGENTINA MFGR#15 80724749
-1997 ARGENTINA MFGR#21 75795929
-1997 ARGENTINA MFGR#22 61932653
-1997 ARGENTINA MFGR#23 98394367
-1997 ARGENTINA MFGR#24 69666059
-1997 ARGENTINA MFGR#25 76900173
-1997 BRAZIL MFGR#11 92141153
-1997 BRAZIL MFGR#12 84364820
-1997 BRAZIL MFGR#13 60152598
-1997 BRAZIL MFGR#14 68822442
-1997 BRAZIL MFGR#15 49647952
-1997 BRAZIL MFGR#21 48001851
-1997 BRAZIL MFGR#22 57586251
-1997 BRAZIL MFGR#23 104789661
-1997 BRAZIL MFGR#24 76057674
-1997 BRAZIL MFGR#25 73807859
-1997 CANADA MFGR#11 57810845
-1997 CANADA MFGR#12 39565355
-1997 CANADA MFGR#13 62795630
-1997 CANADA MFGR#14 74527292
-1997 CANADA MFGR#15 39782846
-1997 CANADA MFGR#21 58809118
-1997 CANADA MFGR#22 34180455
-1997 CANADA MFGR#23 90940750
-1997 CANADA MFGR#24 68977639
-1997 CANADA MFGR#25 69718345
-1997 PERU MFGR#11 86491759
-1997 PERU MFGR#12 38459763
-1997 PERU MFGR#13 74844638
-1997 PERU MFGR#14 33890140
-1997 PERU MFGR#15 51549827
-1997 PERU MFGR#21 45930118
-1997 PERU MFGR#22 79490770
-1997 PERU MFGR#23 81097234
-1997 PERU MFGR#24 42145567
-1997 PERU MFGR#25 93896161
-1997 UNITED STATES MFGR#11 128974616
-1997 UNITED STATES MFGR#12 103852297
-1997 UNITED STATES MFGR#13 111925293
-1997 UNITED STATES MFGR#14 156900557
-1997 UNITED STATES MFGR#15 147809168
-1997 UNITED STATES MFGR#21 112788514
-1997 UNITED STATES MFGR#22 111947464
-1997 UNITED STATES MFGR#23 97287950
-1997 UNITED STATES MFGR#24 133285537
-1997 UNITED STATES MFGR#25 68097673
-1998 ARGENTINA MFGR#11 34265472
-1998 ARGENTINA MFGR#12 38574220
-1998 ARGENTINA MFGR#13 54861309
-1998 ARGENTINA MFGR#14 44132616
-1998 ARGENTINA MFGR#15 46293084
-1998 ARGENTINA MFGR#21 20943149
-1998 ARGENTINA MFGR#22 31396688
-1998 ARGENTINA MFGR#23 33142495
-1998 ARGENTINA MFGR#24 38183235
-1998 ARGENTINA MFGR#25 47966630
-1998 BRAZIL MFGR#11 9682250
-1998 BRAZIL MFGR#12 42674635
-1998 BRAZIL MFGR#13 47806774
-1998 BRAZIL MFGR#14 48944962
-1998 BRAZIL MFGR#15 35897291
-1998 BRAZIL MFGR#21 49067522
-1998 BRAZIL MFGR#22 39261303
-1998 BRAZIL MFGR#23 28969547
-1998 BRAZIL MFGR#24 72118672
-1998 BRAZIL MFGR#25 52144905
-1998 CANADA MFGR#11 23156877
-1998 CANADA MFGR#12 57017498
-1998 CANADA MFGR#13 57600275
-1998 CANADA MFGR#14 9031433
-1998 CANADA MFGR#15 29733304
-1998 CANADA MFGR#21 19140829
-1998 CANADA MFGR#22 35257852
-1998 CANADA MFGR#23 35225991
-1998 CANADA MFGR#24 34724347
-1998 CANADA MFGR#25 13482188
-1998 PERU MFGR#11 25696896
-1998 PERU MFGR#12 46161153
-1998 PERU MFGR#13 26901626
-1998 PERU MFGR#14 38016600
-1998 PERU MFGR#15 19566691
-1998 PERU MFGR#21 24265273
-1998 PERU MFGR#22 25779227
-1998 PERU MFGR#23 39744896
-1998 PERU MFGR#24 42297999
-1998 PERU MFGR#25 38086043
-1998 UNITED STATES MFGR#11 76915262
-1998 UNITED STATES MFGR#12 67705762
-1998 UNITED STATES MFGR#13 85954726
-1998 UNITED STATES MFGR#14 62885468
-1998 UNITED STATES MFGR#15 67836613
-1998 UNITED STATES MFGR#21 63566982
-1998 UNITED STATES MFGR#22 67972090
-1998 UNITED STATES MFGR#23 94697392
-1998 UNITED STATES MFGR#24 87772845
-1998 UNITED STATES MFGR#25 75086780
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.out
deleted file mode 100644
index d3a4df5c1c4..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.out
+++ /dev/null
@@ -1,205 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_flat_q4.3 --
-1997 UNITED ST0 MFGR#1410 13477726
-1997 UNITED ST0 MFGR#1411 1131596
-1997 UNITED ST0 MFGR#1412 1675766
-1997 UNITED ST0 MFGR#1413 9084301
-1997 UNITED ST0 MFGR#1414 10225592
-1997 UNITED ST0 MFGR#1415 61734
-1997 UNITED ST0 MFGR#1416 2081784
-1997 UNITED ST0 MFGR#1418 4280621
-1997 UNITED ST0 MFGR#142 4272322
-1997 UNITED ST0 MFGR#1420 4995802
-1997 UNITED ST0 MFGR#1422 7777485
-1997 UNITED ST0 MFGR#1424 415314
-1997 UNITED ST0 MFGR#1426 2709835
-1997 UNITED ST0 MFGR#1427 1842735
-1997 UNITED ST0 MFGR#1429 11735400
-1997 UNITED ST0 MFGR#143 1408161
-1997 UNITED ST0 MFGR#1432 6900352
-1997 UNITED ST0 MFGR#1433 2773371
-1997 UNITED ST0 MFGR#1434 11633767
-1997 UNITED ST0 MFGR#1435 8022588
-1997 UNITED ST0 MFGR#1436 10900405
-1997 UNITED ST0 MFGR#1437 4883797
-1997 UNITED ST0 MFGR#1439 3947594
-1997 UNITED ST0 MFGR#144 12286295
-1997 UNITED ST0 MFGR#146 3799112
-1997 UNITED ST2 MFGR#141 8618423
-1997 UNITED ST2 MFGR#1410 3307298
-1997 UNITED ST2 MFGR#1411 3890975
-1997 UNITED ST2 MFGR#1414 5676958
-1997 UNITED ST2 MFGR#1415 307670
-1997 UNITED ST2 MFGR#1421 8414075
-1997 UNITED ST2 MFGR#1422 7527974
-1997 UNITED ST2 MFGR#1423 3252824
-1997 UNITED ST2 MFGR#1424 2317371
-1997 UNITED ST2 MFGR#1426 10601349
-1997 UNITED ST2 MFGR#1433 2014845
-1997 UNITED ST2 MFGR#1435 242061
-1997 UNITED ST3 MFGR#1410 3985098
-1997 UNITED ST3 MFGR#1412 10368277
-1997 UNITED ST3 MFGR#1413 7115770
-1997 UNITED ST3 MFGR#1414 7187734
-1997 UNITED ST3 MFGR#1415 1688919
-1997 UNITED ST3 MFGR#1416 7581355
-1997 UNITED ST3 MFGR#1419 178998
-1997 UNITED ST3 MFGR#142 5373798
-1997 UNITED ST3 MFGR#1420 3051498
-1997 UNITED ST3 MFGR#1421 6361174
-1997 UNITED ST3 MFGR#1424 5265213
-1997 UNITED ST3 MFGR#1426 3085943
-1997 UNITED ST3 MFGR#1427 1442686
-1997 UNITED ST3 MFGR#1428 9607764
-1997 UNITED ST3 MFGR#143 8617915
-1997 UNITED ST3 MFGR#1430 11136547
-1997 UNITED ST3 MFGR#1432 10490356
-1997 UNITED ST3 MFGR#1434 4436541
-1997 UNITED ST3 MFGR#1435 145357
-1997 UNITED ST3 MFGR#1436 11636005
-1997 UNITED ST3 MFGR#1437 4734063
-1997 UNITED ST3 MFGR#1438 7866008
-1997 UNITED ST3 MFGR#1439 4003230
-1997 UNITED ST3 MFGR#144 2677841
-1997 UNITED ST3 MFGR#145 769796
-1997 UNITED ST3 MFGR#146 1393223
-1997 UNITED ST3 MFGR#147 13464467
-1997 UNITED ST3 MFGR#148 6894444
-1997 UNITED ST6 MFGR#1410 15314239
-1997 UNITED ST6 MFGR#1413 3296933
-1997 UNITED ST6 MFGR#142 5906623
-1997 UNITED ST6 MFGR#1422 1472298
-1997 UNITED ST6 MFGR#1424 5517883
-1997 UNITED ST6 MFGR#1425 7142620
-1997 UNITED ST6 MFGR#1426 372019
-1997 UNITED ST6 MFGR#1432 4600393
-1997 UNITED ST6 MFGR#1433 13423348
-1997 UNITED ST6 MFGR#1434 1968821
-1997 UNITED ST6 MFGR#1439 4838571
-1997 UNITED ST6 MFGR#147 3587496
-1997 UNITED ST6 MFGR#148 702290
-1997 UNITED ST6 MFGR#149 3420425
-1997 UNITED ST7 MFGR#141 234478
-1997 UNITED ST7 MFGR#1415 7270650
-1997 UNITED ST7 MFGR#1417 3729358
-1997 UNITED ST7 MFGR#1421 1236154
-1997 UNITED ST7 MFGR#1422 1790814
-1997 UNITED ST7 MFGR#1425 3083550
-1997 UNITED ST7 MFGR#1429 405372
-1997 UNITED ST7 MFGR#1430 9415365
-1997 UNITED ST7 MFGR#1431 1924890
-1997 UNITED ST7 MFGR#1434 8824017
-1997 UNITED ST7 MFGR#1436 3210582
-1997 UNITED ST7 MFGR#1438 2282974
-1997 UNITED ST7 MFGR#144 3607000
-1997 UNITED ST7 MFGR#145 4396854
-1997 UNITED ST7 MFGR#147 3872593
-1997 UNITED ST9 MFGR#1410 9705983
-1997 UNITED ST9 MFGR#1412 10366314
-1997 UNITED ST9 MFGR#1414 23471819
-1997 UNITED ST9 MFGR#1416 5079988
-1997 UNITED ST9 MFGR#1417 3909867
-1997 UNITED ST9 MFGR#1418 3542205
-1997 UNITED ST9 MFGR#1421 4807216
-1997 UNITED ST9 MFGR#1422 1601211
-1997 UNITED ST9 MFGR#1424 1046454
-1997 UNITED ST9 MFGR#1425 4189195
-1997 UNITED ST9 MFGR#1427 3301933
-1997 UNITED ST9 MFGR#143 5101762
-1997 UNITED ST9 MFGR#1430 2344496
-1997 UNITED ST9 MFGR#1431 4131978
-1997 UNITED ST9 MFGR#1432 3504323
-1997 UNITED ST9 MFGR#1435 8034673
-1997 UNITED ST9 MFGR#1436 1693656
-1997 UNITED ST9 MFGR#1437 389519
-1997 UNITED ST9 MFGR#1438 11644879
-1997 UNITED ST9 MFGR#144 3475388
-1997 UNITED ST9 MFGR#1440 4829762
-1997 UNITED ST9 MFGR#145 39653
-1997 UNITED ST9 MFGR#146 13853442
-1997 UNITED ST9 MFGR#147 3657668
-1997 UNITED ST9 MFGR#148 7887845
-1997 UNITED ST9 MFGR#149 4352548
-1998 UNITED ST0 MFGR#141 3380910
-1998 UNITED ST0 MFGR#1412 4133188
-1998 UNITED ST0 MFGR#1413 2668812
-1998 UNITED ST0 MFGR#1414 5971689
-1998 UNITED ST0 MFGR#1416 5712462
-1998 UNITED ST0 MFGR#1417 5446709
-1998 UNITED ST0 MFGR#1418 3978748
-1998 UNITED ST0 MFGR#1423 4295756
-1998 UNITED ST0 MFGR#1424 2884437
-1998 UNITED ST0 MFGR#1425 2708911
-1998 UNITED ST0 MFGR#1426 5882143
-1998 UNITED ST0 MFGR#1427 1738417
-1998 UNITED ST0 MFGR#1428 3847110
-1998 UNITED ST0 MFGR#1435 5306378
-1998 UNITED ST0 MFGR#1436 4877671
-1998 UNITED ST0 MFGR#1437 1254408
-1998 UNITED ST0 MFGR#147 3440479
-1998 UNITED ST2 MFGR#1412 3989941
-1998 UNITED ST2 MFGR#1414 2615699
-1998 UNITED ST2 MFGR#1415 1164247
-1998 UNITED ST2 MFGR#1416 1140355
-1998 UNITED ST2 MFGR#142 2914401
-1998 UNITED ST2 MFGR#1430 4795306
-1998 UNITED ST2 MFGR#1432 3987452
-1998 UNITED ST2 MFGR#1433 3452627
-1998 UNITED ST2 MFGR#146 2296424
-1998 UNITED ST2 MFGR#149 6706568
-1998 UNITED ST3 MFGR#1410 4569384
-1998 UNITED ST3 MFGR#1415 2726191
-1998 UNITED ST3 MFGR#1416 5554404
-1998 UNITED ST3 MFGR#1417 8590630
-1998 UNITED ST3 MFGR#1418 920355
-1998 UNITED ST3 MFGR#1421 3044496
-1998 UNITED ST3 MFGR#1422 4335121
-1998 UNITED ST3 MFGR#1423 2625064
-1998 UNITED ST3 MFGR#1427 5563641
-1998 UNITED ST3 MFGR#1428 3310166
-1998 UNITED ST3 MFGR#1429 2142148
-1998 UNITED ST3 MFGR#1431 12064252
-1998 UNITED ST3 MFGR#1434 2678930
-1998 UNITED ST3 MFGR#1435 5573130
-1998 UNITED ST3 MFGR#1437 1179224
-1998 UNITED ST3 MFGR#1438 1110737
-1998 UNITED ST3 MFGR#144 5768414
-1998 UNITED ST3 MFGR#145 6943188
-1998 UNITED ST3 MFGR#146 6264244
-1998 UNITED ST3 MFGR#147 6623163
-1998 UNITED ST6 MFGR#1414 2377768
-1998 UNITED ST6 MFGR#1416 2547588
-1998 UNITED ST6 MFGR#1419 4889639
-1998 UNITED ST6 MFGR#142 4218991
-1998 UNITED ST6 MFGR#1427 5151664
-1998 UNITED ST6 MFGR#1432 4737390
-1998 UNITED ST6 MFGR#1435 379286
-1998 UNITED ST6 MFGR#1439 3255983
-1998 UNITED ST6 MFGR#144 2557646
-1998 UNITED ST6 MFGR#1440 2377229
-1998 UNITED ST7 MFGR#141 2482134
-1998 UNITED ST7 MFGR#1410 5139336
-1998 UNITED ST7 MFGR#1413 4188060
-1998 UNITED ST7 MFGR#1415 4914228
-1998 UNITED ST7 MFGR#1418 3723433
-1998 UNITED ST7 MFGR#1421 2916659
-1998 UNITED ST7 MFGR#143 1427968
-1998 UNITED ST7 MFGR#1431 1723135
-1998 UNITED ST7 MFGR#1436 3384193
-1998 UNITED ST7 MFGR#1437 3885888
-1998 UNITED ST7 MFGR#1438 6004902
-1998 UNITED ST7 MFGR#1439 2611386
-1998 UNITED ST7 MFGR#144 2322930
-1998 UNITED ST9 MFGR#1413 13244182
-1998 UNITED ST9 MFGR#1414 3962036
-1998 UNITED ST9 MFGR#1415 5012323
-1998 UNITED ST9 MFGR#1419 1926911
-1998 UNITED ST9 MFGR#1428 3816952
-1998 UNITED ST9 MFGR#143 2438736
-1998 UNITED ST9 MFGR#1430 2182673
-1998 UNITED ST9 MFGR#1432 2749769
-1998 UNITED ST9 MFGR#1435 9924298
-1998 UNITED ST9 MFGR#1437 8516771
-1998 UNITED ST9 MFGR#1438 5374476
-1998 UNITED ST9 MFGR#149 4740736
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.1.out
deleted file mode 100644
index 18b73f7c8f3..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.1.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q1.1 --
-\N
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.2.out
deleted file mode 100644
index 957de43c5a9..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.2.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q1.2 --
-\N
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.3.out
deleted file mode 100644
index 74885b987cf..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.3.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q1.3 --
-\N
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.1.out
deleted file mode 100644
index 20133ec5806..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.1.out
+++ /dev/null
@@ -1,43 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q2.1 --
-29165996 1992 MFGR#121
-23120066 1992 MFGR#1210
-52982362 1992 MFGR#1211
-30954680 1992 MFGR#1212
-15288453 1992 MFGR#1213
-7655070 1992 MFGR#1214
-22246540 1992 MFGR#1215
-19716439 1992 MFGR#1216
-43666251 1992 MFGR#1217
-22759602 1992 MFGR#1218
-23318799 1992 MFGR#1219
-74056106 1992 MFGR#122
-51050565 1992 MFGR#1220
-38878674 1992 MFGR#1221
-16558051 1992 MFGR#1222
-26690787 1992 MFGR#1223
-76498594 1992 MFGR#1224
-32608903 1992 MFGR#1225
-47636685 1992 MFGR#1226
-27691433 1992 MFGR#1227
-32513490 1992 MFGR#1228
-35514258 1992 MFGR#1229
-17199862 1992 MFGR#123
-24678908 1992 MFGR#1230
-26231337 1992 MFGR#1231
-36330900 1992 MFGR#1232
-24946678 1992 MFGR#1233
-36431683 1992 MFGR#1234
-39368479 1992 MFGR#1235
-44456974 1992 MFGR#1236
-31443810 1992 MFGR#1237
-49003021 1992 MFGR#1238
-31379822 1992 MFGR#1239
-24245603 1992 MFGR#124
-49870826 1992 MFGR#1240
-28194770 1992 MFGR#125
-40503844 1992 MFGR#126
-36027836 1992 MFGR#127
-35881895 1992 MFGR#128
-21732451 1992 MFGR#129
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.2.out
deleted file mode 100644
index 857ff7e84a9..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.2.out
+++ /dev/null
@@ -1,11 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q2.2 --
-28235270 1992 MFGR#2221
-64071827 1992 MFGR#2222
-48591160 1992 MFGR#2223
-20416501 1992 MFGR#2224
-74950776 1992 MFGR#2225
-60628045 1992 MFGR#2226
-39273349 1992 MFGR#2227
-66658087 1992 MFGR#2228
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.3.out
deleted file mode 100644
index a074f3cd1f8..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.3.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q2.3 --
-89380397 1992 MFGR#2239
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.1.out
deleted file mode 100644
index 9fe447c3023..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.1.out
+++ /dev/null
@@ -1,28 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q3.1 --
-JAPAN CHINA 1992 637991852
-VIETNAM CHINA 1992 621845377
-INDONESIA CHINA 1992 621316255
-CHINA CHINA 1992 614550901
-INDIA CHINA 1992 561966207
-INDIA INDONESIA 1992 487449629
-INDONESIA INDONESIA 1992 477417717
-JAPAN INDONESIA 1992 476513261
-JAPAN VIETNAM 1992 468999429
-INDONESIA JAPAN 1992 465870469
-VIETNAM INDONESIA 1992 462424521
-INDIA JAPAN 1992 412186106
-JAPAN JAPAN 1992 399179790
-VIETNAM JAPAN 1992 395247587
-JAPAN INDIA 1992 393835589
-CHINA INDONESIA 1992 352903905
-CHINA INDIA 1992 348359904
-VIETNAM VIETNAM 1992 342176333
-INDIA VIETNAM 1992 334582962
-INDIA INDIA 1992 329354089
-CHINA JAPAN 1992 327558220
-CHINA VIETNAM 1992 324763767
-INDONESIA INDIA 1992 310417666
-VIETNAM INDIA 1992 296225919
-INDONESIA VIETNAM 1992 278083418
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.2.out
deleted file mode 100644
index c6d50e75e64..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.2.out
+++ /dev/null
@@ -1,51 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q3.2 --
-UNITED ST4 UNITED ST0 1992 34626982
-UNITED ST4 UNITED ST3 1992 29767238
-UNITED ST1 UNITED ST9 1992 25644597
-UNITED ST2 UNITED ST0 1992 23943154
-UNITED ST4 UNITED ST9 1992 21189183
-UNITED ST0 UNITED ST0 1992 18293852
-UNITED ST7 UNITED ST3 1992 17996772
-UNITED ST9 UNITED ST3 1992 17863433
-UNITED ST1 UNITED ST7 1992 17410800
-UNITED ST2 UNITED ST3 1992 15331073
-UNITED ST5 UNITED ST9 1992 14448179
-UNITED ST1 UNITED ST3 1992 13938002
-UNITED ST5 UNITED ST6 1992 12398029
-UNITED ST9 UNITED ST2 1992 12370917
-UNITED ST2 UNITED ST9 1992 12343455
-UNITED ST5 UNITED ST0 1992 12301234
-UNITED ST6 UNITED ST0 1992 11900889
-UNITED ST4 UNITED ST2 1992 11696334
-UNITED ST4 UNITED ST6 1992 11369008
-UNITED ST1 UNITED ST6 1992 11000283
-UNITED ST1 UNITED ST0 1992 10878084
-UNITED ST4 UNITED ST7 1992 10151573
-UNITED ST5 UNITED ST2 1992 9917834
-UNITED ST7 UNITED ST7 1992 9715656
-UNITED ST6 UNITED ST6 1992 8685228
-UNITED ST2 UNITED ST2 1992 8313714
-UNITED ST1 UNITED ST2 1992 8004700
-UNITED ST2 UNITED ST7 1992 7759164
-UNITED ST0 UNITED ST7 1992 7137641
-UNITED ST9 UNITED ST7 1992 6703890
-UNITED ST6 UNITED ST9 1992 6597261
-UNITED ST7 UNITED ST2 1992 6125476
-UNITED ST7 UNITED ST6 1992 6058017
-UNITED ST5 UNITED ST3 1992 5862031
-UNITED ST8 UNITED ST9 1992 5690491
-UNITED ST7 UNITED ST9 1992 5403152
-UNITED ST9 UNITED ST0 1992 4816370
-UNITED ST9 UNITED ST9 1992 4234523
-UNITED ST3 UNITED ST3 1992 4080199
-UNITED ST5 UNITED ST7 1992 3936271
-UNITED ST8 UNITED ST0 1992 3574169
-UNITED ST0 UNITED ST3 1992 3201624
-UNITED ST3 UNITED ST9 1992 2614811
-UNITED ST8 UNITED ST7 1992 2373825
-UNITED ST9 UNITED ST6 1992 2066609
-UNITED ST7 UNITED ST0 1992 1882015
-UNITED ST6 UNITED ST3 1992 1873819
-UNITED ST6 UNITED ST2 1992 291566
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.3.out
deleted file mode 100644
index 40d97f365f4..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.3.out
+++ /dev/null
@@ -1,4 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q3.3 --
-UNITED KI5 UNITED KI1 1992 4397192
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.4.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.4.out
deleted file mode 100644
index f913bd61335..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.4.out
+++ /dev/null
@@ -1,3 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q3.4 --
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.1.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.1.out
deleted file mode 100644
index fb27c3b0528..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.1.out
+++ /dev/null
@@ -1,8 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q4.1 --
-1992 ARGENTINA 533196600
-1992 BRAZIL 684224630
-1992 CANADA 532686194
-1992 PERU 586223155
-1992 UNITED STATES 682387184
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.2.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.2.out
deleted file mode 100644
index b3ebde63002..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.2.out
+++ /dev/null
@@ -1,3 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q4.2 --
-
diff --git a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.3.out
b/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.3.out
deleted file mode 100644
index 825942a3aea..00000000000
--- a/regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.3.out
+++ /dev/null
@@ -1,3 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !pipelinex_q4.3 --
-
diff --git
a/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
b/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
index 757bdd330d4..b2ad94dd2a2 100644
--- a/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
+++ b/regression-test/suites/cloud_p0/query_retry/test_retry_e-230.groovy
@@ -53,7 +53,6 @@ suite("test_retry_e-230", 'docker') {
sql """ DROP TABLE IF EXISTS ${tbl1} """
sql """ DROP TABLE IF EXISTS ${tbl2} """
try {
- sql """set global
experimental_enable_pipeline_x_engine=false"""
cluster.injectDebugPoints(NodeType.BE,
['CloudTablet.capture_rs_readers.return.e-230' : null])
sql """
diff --git
a/regression-test/suites/correctness_p0/test_distinct_streaming_agg_local_shuffle.groovy
b/regression-test/suites/correctness_p0/test_distinct_streaming_agg_local_shuffle.groovy
index 5a6b469cb1c..a86bbe05fd0 100644
---
a/regression-test/suites/correctness_p0/test_distinct_streaming_agg_local_shuffle.groovy
+++
b/regression-test/suites/correctness_p0/test_distinct_streaming_agg_local_shuffle.groovy
@@ -77,7 +77,6 @@ suite("test_distinct_streaming_agg_local_shuffle") {
insert into
table_10_undef_partitions2_keys3_properties4_distributed_by53(pk,col_bigint_undef_signed,col_varchar_10__undef_signed,col_varchar_64__undef_signed)
values
(0,null,'right','g'),(1,-486256,'on','on'),(2,-1,'I''ll','at'),(3,29263,'h','don''t'),(4,5453,'a','s'),(5,-119,'j','can''t'),(6,89,'one','n'),(7,-7227,'s','u'),(8,94,'time','b'),(9,1816630,'yes','yes');
"""
- sql """set experimental_enable_pipeline_x_engine=true"""
sql """set enable_local_shuffle = true"""
qt_select """
@@ -87,8 +86,6 @@ suite("test_distinct_streaming_agg_local_shuffle") {
"""
-
- sql """set experimental_enable_pipeline_x_engine=false"""
sql """set enable_local_shuffle = false"""
diff --git
a/regression-test/suites/correctness_p0/test_grouping_sets_empty.groovy
b/regression-test/suites/correctness_p0/test_grouping_sets_empty.groovy
index 664420c8fa2..b0bd6b19039 100644
--- a/regression-test/suites/correctness_p0/test_grouping_sets_empty.groovy
+++ b/regression-test/suites/correctness_p0/test_grouping_sets_empty.groovy
@@ -29,11 +29,6 @@ suite("test_grouping_sets_empty") {
insert into test_grouping_sets_empty values (1),(2),(3);
"""
-
- sql """
- set experimental_enable_pipeline_x_engine=true;
- """
-
qt_select1 """
select count(a) from test_grouping_sets_empty group by grouping sets
(());
"""
diff --git a/regression-test/suites/correctness_p0/test_probe_clean.groovy
b/regression-test/suites/correctness_p0/test_probe_clean.groovy
index 6e9ded37259..1ee5cba18f8 100644
--- a/regression-test/suites/correctness_p0/test_probe_clean.groovy
+++ b/regression-test/suites/correctness_p0/test_probe_clean.groovy
@@ -61,32 +61,11 @@ sql """
insert into clearblocktable2 values(1,1,'2020-01-01');
"""
-sql """
-set enable_pipeline_x_engine=true, enable_pipeline_engine=true;
-"""
qt_select_pipelineX """
SELECT YEAR(ifnull(clearblocktable1.`col_date_undef_signed_not_null`,
clearblocktable1.`col_date_undef_signed_not_null`)) AS field1 ,
CASE WHEN clearblocktable1.`col_int_undef_signed` !=
clearblocktable1.`col_int_undef_signed` * (8 + 1) THEN -5.2 ELSE
clearblocktable1.`col_int_undef_signed` END AS field2
FROM clearblocktable1 INNER JOIN clearblocktable2 ON
clearblocktable2.`col_int_undef_signed` =
clearblocktable1.`col_int_undef_signed` WHERE
clearblocktable1.`col_int_undef_signed_not_null` <> 7;
-"""
-
-sql """
-set enable_pipeline_x_engine=false,enable_pipeline_engine=true;
-"""
-qt_select_pipeline """
-
-SELECT YEAR(ifnull(clearblocktable1.`col_date_undef_signed_not_null`,
clearblocktable1.`col_date_undef_signed_not_null`)) AS field1 ,
-CASE WHEN clearblocktable1.`col_int_undef_signed` !=
clearblocktable1.`col_int_undef_signed` * (8 + 1) THEN -5.2 ELSE
clearblocktable1.`col_int_undef_signed` END AS field2
-FROM clearblocktable1 INNER JOIN clearblocktable2 ON
clearblocktable2.`col_int_undef_signed` =
clearblocktable1.`col_int_undef_signed` WHERE
clearblocktable1.`col_int_undef_signed_not_null` <> 7;
-
-"""
-
-qt_select_non_pipeline """
-
-SELECT YEAR(ifnull(clearblocktable1.`col_date_undef_signed_not_null`,
clearblocktable1.`col_date_undef_signed_not_null`)) AS field1 ,
-CASE WHEN clearblocktable1.`col_int_undef_signed` !=
clearblocktable1.`col_int_undef_signed` * (8 + 1) THEN -5.2 ELSE
clearblocktable1.`col_int_undef_signed` END AS field2
-FROM clearblocktable1 INNER JOIN clearblocktable2 ON
clearblocktable2.`col_int_undef_signed` =
clearblocktable1.`col_int_undef_signed` WHERE
clearblocktable1.`col_int_undef_signed_not_null` <> 7;
"""
}
diff --git
a/regression-test/suites/load_p0/insert/test_insert_move_memtable.groovy
b/regression-test/suites/load_p0/insert/test_insert_move_memtable.groovy
deleted file mode 100644
index a0eb38c0b97..00000000000
--- a/regression-test/suites/load_p0/insert/test_insert_move_memtable.groovy
+++ /dev/null
@@ -1,119 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("test_insert_move_memtable") {
- sql """ set enable_memtable_on_sink_node=true """
- sql """ set experimental_enable_pipeline_x_engine=false """
- // todo: test insert, such as insert values, insert select, insert txn
- sql "show load"
- def test_baseall = "test_query_db.baseall";
- def test_bigtable = "test_query_db.bigtable";
- def insert_tbl = "test_insert_tbl_mm";
-
- sql """ DROP TABLE IF EXISTS ${insert_tbl}"""
- sql """
- CREATE TABLE ${insert_tbl} (
- `k1` char(5) NULL,
- `k2` int(11) NULL,
- `k3` tinyint(4) NULL,
- `k4` int(11) NULL
- ) ENGINE=OLAP
- DUPLICATE KEY(`k1`, `k2`, `k3`, `k4`)
- COMMENT 'OLAP'
- DISTRIBUTED BY HASH(`k1`) BUCKETS 5
- PROPERTIES (
- "replication_num"="1"
- );
- """
-
- sql """
- INSERT INTO ${insert_tbl}
- SELECT a.k6, a.k3, b.k1
- , sum(b.k1) OVER (PARTITION BY a.k6 ORDER BY a.k3) AS w_sum
- FROM ${test_baseall} a
- JOIN ${test_bigtable} b ON a.k1 = b.k1 + 5
- ORDER BY a.k6, a.k3, a.k1, w_sum
- """
-
- qt_sql1 "select * from ${insert_tbl} order by 1, 2, 3, 4"
-
- def insert_tbl2 = "test_insert_tbl_no_light_schema_change";
-
- sql """ DROP TABLE IF EXISTS ${insert_tbl2}"""
- sql """
- CREATE TABLE ${insert_tbl2} (
- `k1` char(5) NULL,
- `k2` int(11) NULL,
- `k3` tinyint(4) NULL,
- `k4` int(11) NULL
- ) ENGINE=OLAP
- DUPLICATE KEY(`k1`, `k2`, `k3`, `k4`)
- COMMENT 'OLAP'
- DISTRIBUTED BY HASH(`k1`) BUCKETS 5
- PROPERTIES (
- "replication_num"="1",
- "light_schema_change" = "false"
- );
- """
-
- sql """
- INSERT INTO ${insert_tbl2}
- SELECT a.k6, a.k3, b.k1
- , sum(b.k1) OVER (PARTITION BY a.k6 ORDER BY a.k3) AS w_sum
- FROM ${test_baseall} a
- JOIN ${test_bigtable} b ON a.k1 = b.k1 + 5
- ORDER BY a.k6, a.k3, a.k1, w_sum
- """
-
- qt_sql2 "select * from ${insert_tbl2} order by 1, 2, 3, 4"
-
- def insert_tbl_dft = "test_insert_dft_tbl_mm"
- sql """ DROP TABLE IF EXISTS ${insert_tbl_dft}"""
-
- // `k7` should be float type, and bug exists now,
https://github.com/apache/doris/pull/20867
- // `k9` should be char(16), and bug exists now as error msg raised:"can
not cast from origin type TINYINT to target type=CHAR(16)" when doing insert
- // "`k13` datetime default CURRENT_TIMESTAMP" might have cast error in
strict mode when doing insert:
- // [INTERNAL_ERROR]Invalid value in strict mode for function CAST, source
column String, from type String to type DateTimeV2
- sql """
- CREATE TABLE ${insert_tbl_dft} (
- `k1` boolean default "true",
- `k2` tinyint default "10",
- `k3` smallint default "10000",
- `k4` int default "10000000",
- `k5` bigint default "92233720368547758",
- `k6` largeint default "19223372036854775807",
-
- `k8` double default "3.14159",
-
- `k10` varchar(64) default "hello world, today is 15/06/2023",
- `k11` date default "2023-06-15",
- `k12` datetime default "2023-06-15 16:10:15"
- ) ENGINE=OLAP
- DUPLICATE KEY(`k1`)
- COMMENT 'OLAP'
- DISTRIBUTED BY HASH(`k1`) BUCKETS 5
- PROPERTIES (
- "replication_num"="1"
- );
- """
-
- sql """ insert into ${insert_tbl_dft} values() """
- sql """ insert into ${insert_tbl_dft} values() """
-
- qt_select """ select k1,k2,k3,k4,k5,k6,k8,k10,k11,k12 from
${insert_tbl_dft} """
- sql """ set enable_memtable_on_sink_node=false """
-}
diff --git
a/regression-test/suites/nereids_p0/session_variable/test_default_limit.groovy
b/regression-test/suites/nereids_p0/session_variable/test_default_limit.groovy
index 214f4a304cb..7be75bfd5ab 100644
---
a/regression-test/suites/nereids_p0/session_variable/test_default_limit.groovy
+++
b/regression-test/suites/nereids_p0/session_variable/test_default_limit.groovy
@@ -51,13 +51,7 @@ suite('test_default_limit') {
sql "insert into baseall values (null, null, null)"
sql "insert into bigtable select * from baseall"
- for (int i = 0; i < 2; ++i) {
- if (i == 0) {
- sql 'set enable_pipeline_engine=false'
- } else if (i == 1) {
- sql 'set enable_pipeline_engine=true'
- }
-
+ for (int i = 0; i < 1; ++i) {
sql 'set default_order_by_limit = -1'
sql 'set sql_select_limit = -1'
diff --git
a/regression-test/suites/nereids_p0/sql_functions/conditional_functions/test_nullif.groovy
b/regression-test/suites/nereids_p0/sql_functions/conditional_functions/test_nullif.groovy
index 9223d98dc3b..c4d469543fd 100644
---
a/regression-test/suites/nereids_p0/sql_functions/conditional_functions/test_nullif.groovy
+++
b/regression-test/suites/nereids_p0/sql_functions/conditional_functions/test_nullif.groovy
@@ -99,11 +99,11 @@ suite("test_nullif") {
qt_if_nullif8 """select ifnull(b.k1, -1) k1 from baseall a left join
bigtable b on a.k1 = b.k1 + 5
order by a.k1"""
// make sure stable
- qt_if_nullif8_1 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_2 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_3 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_4 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_5 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_1 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_2 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_3 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_4 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_5 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
qt_if_nullif10 """select ifnull(b.k6, "hll") k1 from baseall a left join
bigtable b on a.k1 = b.k1 + 5
order by k1"""
qt_if_nullif11 """select ifnull(b.k10, "2017-06-06") k1 from baseall a
left join bigtable b on
diff --git a/regression-test/suites/query_p0/join/test_join_result_count.groovy
b/regression-test/suites/query_p0/join/test_join_result_count.groovy
index d14cb8c2393..34871ea1858 100644
--- a/regression-test/suites/query_p0/join/test_join_result_count.groovy
+++ b/regression-test/suites/query_p0/join/test_join_result_count.groovy
@@ -152,9 +152,6 @@ INSERT INTO `t4` VALUES
(NULL,'4M','DORIS','td','1','kQ','6G','XM','k3','Jp','02
sql """
set parallel_pipeline_task_num = 1;
-"""
- sql """
-set enable_pipeline_engine = 0;
"""
sql """
set enable_profile = 1;
diff --git
a/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy
b/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy
index 27a4f7db164..956236a9f4e 100644
--- a/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy
+++ b/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy
@@ -65,7 +65,7 @@ suite("test_partitioned_hash_join",
"query,p0,arrow_flight_sql") {
qt_partitioned_hash_join1 """
select
-
/*+SET_VAR(disable_join_reorder=true,experimental_enable_pipeline_engine=false)*/
+ /*+SET_VAR(disable_join_reorder=true)*/
kl1
from
test_partitioned_hash_join_l
diff --git
a/regression-test/suites/query_p0/schema_table/test_active_queries.groovy
b/regression-test/suites/query_p0/schema_table/test_active_queries.groovy
index b5a0a961508..7bca2b5e02b 100644
--- a/regression-test/suites/query_p0/schema_table/test_active_queries.groovy
+++ b/regression-test/suites/query_p0/schema_table/test_active_queries.groovy
@@ -18,21 +18,6 @@
suite("test_active_queries") {
def thread1 = new Thread({
for (int i = 0; i <= 300; i++) {
- // non-pipeline
- sql "set experimental_enable_pipeline_engine=false"
- sql "set experimental_enable_pipeline_x_engine=false"
- sql "select * from information_schema.active_queries"
- sql "select
QUERY_ID,QUERY_START_TIME,QUERY_TIME_MS,WORKLOAD_GROUP_ID,SQL,QUERY_STATUS,USER
from information_schema.active_queries"
-
- // pipeline
- sql "set experimental_enable_pipeline_engine=true"
- sql "set experimental_enable_pipeline_x_engine=false"
- sql "select * from information_schema.active_queries"
- sql "select
QUERY_ID,QUERY_START_TIME,QUERY_TIME_MS,WORKLOAD_GROUP_ID,SQL,QUERY_STATUS,USER
from information_schema.active_queries"
-
- // pipelinex
- sql "set experimental_enable_pipeline_engine=true"
- sql "set experimental_enable_pipeline_x_engine=true"
sql "select * from information_schema.active_queries"
sql "select
QUERY_ID,QUERY_START_TIME,QUERY_TIME_MS,WORKLOAD_GROUP_ID,SQL,QUERY_STATUS,USER
from information_schema.active_queries"
Thread.sleep(1000)
diff --git
a/regression-test/suites/query_p0/schema_table/test_backend_active_tasks.groovy
b/regression-test/suites/query_p0/schema_table/test_backend_active_tasks.groovy
index f0d93fc43c9..22cf3708d7f 100644
---
a/regression-test/suites/query_p0/schema_table/test_backend_active_tasks.groovy
+++
b/regression-test/suites/query_p0/schema_table/test_backend_active_tasks.groovy
@@ -18,21 +18,6 @@
suite("test_backend_active_tasks") {
def thread1 = new Thread({
for (int i = 0; i <= 300; i++) {
- // non-pipeline
- sql "set experimental_enable_pipeline_engine=false"
- sql "set experimental_enable_pipeline_x_engine=false"
- sql "select * from information_schema.backend_active_tasks"
- sql "select BE_ID,FE_HOST,QUERY_ID,SCAN_ROWS from
information_schema.backend_active_tasks"
-
- // pipeline
- sql "set experimental_enable_pipeline_engine=true"
- sql "set experimental_enable_pipeline_x_engine=false"
- sql "select * from information_schema.backend_active_tasks"
- sql "select BE_ID,FE_HOST,QUERY_ID,SCAN_ROWS from
information_schema.backend_active_tasks"
-
- // pipelinex
- sql "set experimental_enable_pipeline_engine=true"
- sql "set experimental_enable_pipeline_x_engine=true"
sql "select * from information_schema.backend_active_tasks"
sql "select BE_ID,FE_HOST,QUERY_ID,SCAN_ROWS from
information_schema.backend_active_tasks"
Thread.sleep(1000)
diff --git
a/regression-test/suites/query_p0/session_variable/test_default_limit.groovy
b/regression-test/suites/query_p0/session_variable/test_default_limit.groovy
index 2ce3b647142..46cc0635025 100644
--- a/regression-test/suites/query_p0/session_variable/test_default_limit.groovy
+++ b/regression-test/suites/query_p0/session_variable/test_default_limit.groovy
@@ -48,13 +48,7 @@ suite('test_default_limit', "arrow_flight_sql") {
sql "insert into baseall values (null, null, null)"
sql "insert into bigtable select * from baseall"
- for (int i = 0; i < 2; ++i) {
- if (i == 0) {
- sql 'set enable_pipeline_engine=false'
- } else if (i == 1) {
- sql 'set enable_pipeline_engine=true'
- }
-
+ for (int i = 0; i < 1; ++i) {
sql 'set default_order_by_limit = -1'
sql 'set sql_select_limit = -1'
diff --git
a/regression-test/suites/query_p0/sql_functions/array_functions/test_array_map_function.groovy
b/regression-test/suites/query_p0/sql_functions/array_functions/test_array_map_function.groovy
index fb67352a0d4..a7737f68a31 100644
---
a/regression-test/suites/query_p0/sql_functions/array_functions/test_array_map_function.groovy
+++
b/regression-test/suites/query_p0/sql_functions/array_functions/test_array_map_function.groovy
@@ -85,14 +85,6 @@ suite("test_array_map_function") {
(12, [1,2,3], [10,20]),
(13, [2,3,4], [10,20,30,40])
"""
-
- test {
- sql"""select
/*+SET_VAR(experimental_enable_pipeline_engine=false)*/ array_map((x,y)->x+y,
c_array1, c_array2) from ${tableName} where id > 10 order by id"""
- check{result, exception, startTime, endTime ->
- assertTrue(exception != null)
- logger.info(exception.message)
- }
- }
test {
sql"""select
/*+SET_VAR(experimental_enable_pipeline_engine=true)*/ array_map((x,y)->x+y,
c_array1, c_array2) from ${tableName} where id > 10 order by id"""
diff --git
a/regression-test/suites/query_p0/sql_functions/bitmap_functions/test_bitmap_function.groovy
b/regression-test/suites/query_p0/sql_functions/bitmap_functions/test_bitmap_function.groovy
index d1725b71c10..4a390cde184 100644
---
a/regression-test/suites/query_p0/sql_functions/bitmap_functions/test_bitmap_function.groovy
+++
b/regression-test/suites/query_p0/sql_functions/bitmap_functions/test_bitmap_function.groovy
@@ -765,32 +765,6 @@ suite("test_bitmap_function") {
insert into test_orthog_bitmap_intersect
select 0, 1, to_bitmap(1) as id_bitmap;
"""
- // test function orthogonal_bitmap_intersect
- // TODO: case will stuck untile timeout, enable it when pipeline bug is
fixed
- // test pipeline
- // sql """ set experimental_enable_pipeline_engine=true; """
- // qt_sql_orthogonal_bitmap_intersect_nereids0 """
- // select count(distinct if(type=1, id,null)) as count1,
- // bitmap_count(orthogonal_bitmap_intersect(id_bitmap, type, 1))
as count2_bitmap from test_orthog_bitmap_intersect;
- // """
- // sql """ set experimental_enable_pipeline_engine=false; """
- // qt_sql_orthogonal_bitmap_intersect_nereids1 """
- // select count(distinct tag) as count1,
- // bitmap_count(orthogonal_bitmap_intersect(id_bitmap, tag, 0)) as
count2_bitmap from test_orthog_bitmap_intersect;
- // """
-
- // test function orthogonal_bitmap_intersect_count
- // test pipeline
- // sql """ set experimental_enable_pipeline_engine=true; """
- // qt_sql_orthogonal_bitmap_intersect_count_nereids0 """
- // select count(distinct tag) as count1,
- // orthogonal_bitmap_intersect_count(id_bitmap, tag, 0) as
count2_bitmap from test_orthog_bitmap_intersect;
- // """
- // sql """ set experimental_enable_pipeline_engine=false; """
- // qt_sql_orthogonal_bitmap_intersect_count_nereids1 """
- // select count(distinct tag) as count1,
- // orthogonal_bitmap_intersect_count(id_bitmap, tag, 0) as
count2_bitmap from test_orthog_bitmap_intersect;
- // """
/////////////////////////////
// test bitmap base64
diff --git
a/regression-test/suites/query_p0/sql_functions/conditional_functions/test_nullif.groovy
b/regression-test/suites/query_p0/sql_functions/conditional_functions/test_nullif.groovy
index 9241b09fe17..c3110d69f7a 100644
---
a/regression-test/suites/query_p0/sql_functions/conditional_functions/test_nullif.groovy
+++
b/regression-test/suites/query_p0/sql_functions/conditional_functions/test_nullif.groovy
@@ -97,11 +97,11 @@ suite("test_nullif") {
qt_if_nullif8 """select ifnull(b.k1, -1) k1 from baseall a left join
bigtable b on a.k1 = b.k1 + 5
order by a.k1"""
// make sure stable
- qt_if_nullif8_1 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_2 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_3 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_4 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
- qt_if_nullif8_5 """select /*+
SET_VAR(enable_pipeline_engine=false,parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_1 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_2 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_3 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_4 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
+ qt_if_nullif8_5 """select /*+
SET_VAR(parallel_pipeline_task_num=2,enable_share_hash_table_for_broadcast_join=true)
*/ b.k1, ifnull(b.k1, -1) k1 from baseall a left join bigtable b on a.k1 =
b.k1 + 5 order by a.k1;"""
qt_if_nullif10 """select ifnull(b.k6, "hll") k1 from baseall a left join
bigtable b on a.k1 = b.k1 + 5
order by k1"""
qt_if_nullif11 """select ifnull(b.k10, "2017-06-06") k1 from baseall a
left join bigtable b on
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql
deleted file mode 100644
index c3d19b67a28..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql
+++ /dev/null
@@ -1,24 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(LO_EXTENDEDPRICE * LO_DISCOUNT) AS revenue
-FROM lineorder_flat
-WHERE
- LO_ORDERDATE >= 19930101
- AND LO_ORDERDATE <= 19931231
- AND LO_DISCOUNT BETWEEN 1 AND 3
- AND LO_QUANTITY < 25;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql
deleted file mode 100644
index 6ab6ceea340..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql
+++ /dev/null
@@ -1,24 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q1.2
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(LO_EXTENDEDPRICE * LO_DISCOUNT) AS revenue
-FROM lineorder_flat
-WHERE
- LO_ORDERDATE >= 19940101
- AND LO_ORDERDATE <= 19940131
- AND LO_DISCOUNT BETWEEN 4 AND 6
- AND LO_QUANTITY BETWEEN 26 AND 35;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql
deleted file mode 100644
index 70796c2a954..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql
+++ /dev/null
@@ -1,25 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q1.3
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(LO_EXTENDEDPRICE * LO_DISCOUNT) AS revenue
-FROM lineorder_flat
-WHERE
- weekofyear(LO_ORDERDATE) = 6
- AND LO_ORDERDATE >= 19940101
- AND LO_ORDERDATE <= 19941231
- AND LO_DISCOUNT BETWEEN 5 AND 7
- AND LO_QUANTITY BETWEEN 26 AND 35;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql
deleted file mode 100644
index 57f2ada2964..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql
+++ /dev/null
@@ -1,24 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q2.1
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- SUM(LO_REVENUE), (LO_ORDERDATE DIV 10000) AS YEAR,
- P_BRAND
-FROM lineorder_flat
-WHERE P_CATEGORY = 'MFGR#12' AND S_REGION = 'AMERICA'
-GROUP BY YEAR, P_BRAND
-ORDER BY YEAR, P_BRAND;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql
deleted file mode 100644
index 9b7a5db502f..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql
+++ /dev/null
@@ -1,27 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q2.2
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- SUM(LO_REVENUE), (LO_ORDERDATE DIV 10000) AS YEAR,
- P_BRAND
-FROM lineorder_flat
-WHERE
- P_BRAND >= 'MFGR#2221'
- AND P_BRAND <= 'MFGR#2228'
- AND S_REGION = 'ASIA'
-GROUP BY YEAR, P_BRAND
-ORDER BY YEAR, P_BRAND;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql
deleted file mode 100644
index 3a8a5e74d48..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql
+++ /dev/null
@@ -1,26 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q2.3
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- SUM(LO_REVENUE), (LO_ORDERDATE DIV 10000) AS YEAR,
- P_BRAND
-FROM lineorder_flat
-WHERE
- P_BRAND = 'MFGR#2239'
- AND S_REGION = 'EUROPE'
-GROUP BY YEAR, P_BRAND
-ORDER BY YEAR, P_BRAND;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql
deleted file mode 100644
index 6b3257f1f3b..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql
+++ /dev/null
@@ -1,29 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q3.1
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- C_NATION,
- S_NATION, (LO_ORDERDATE DIV 10000) AS YEAR,
- SUM(LO_REVENUE) AS revenue
-FROM lineorder_flat
-WHERE
- C_REGION = 'ASIA'
- AND S_REGION = 'ASIA'
- AND LO_ORDERDATE >= 19920101
- AND LO_ORDERDATE <= 19971231
-GROUP BY C_NATION, S_NATION, YEAR
-ORDER BY YEAR ASC, revenue DESC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql
deleted file mode 100644
index fefe727da82..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql
+++ /dev/null
@@ -1,29 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q3.2
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- C_CITY,
- S_CITY, (LO_ORDERDATE DIV 10000) AS YEAR,
- SUM(LO_REVENUE) AS revenue
-FROM lineorder_flat
-WHERE
- C_NATION = 'UNITED STATES'
- AND S_NATION = 'UNITED STATES'
- AND LO_ORDERDATE >= 19920101
- AND LO_ORDERDATE <= 19971231
-GROUP BY C_CITY, S_CITY, YEAR
-ORDER BY YEAR ASC, revenue DESC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql
deleted file mode 100644
index c4560b701ed..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql
+++ /dev/null
@@ -1,29 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q3.3
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- C_CITY,
- S_CITY, (LO_ORDERDATE DIV 10000) AS YEAR,
- SUM(LO_REVENUE) AS revenue
-FROM lineorder_flat
-WHERE
- C_CITY IN ('UNITED KI1', 'UNITED KI5')
- AND S_CITY IN ('UNITED KI1', 'UNITED KI5')
- AND LO_ORDERDATE >= 19920101
- AND LO_ORDERDATE <= 19971231
-GROUP BY C_CITY, S_CITY, YEAR
-ORDER BY YEAR ASC, revenue DESC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql
deleted file mode 100644
index 4ae5d956e48..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql
+++ /dev/null
@@ -1,29 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q3.4
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
- C_CITY,
- S_CITY, (LO_ORDERDATE DIV 10000) AS YEAR,
- SUM(LO_REVENUE) AS revenue
-FROM lineorder_flat
-WHERE
- C_CITY IN ('UNITED KI1', 'UNITED KI5')
- AND S_CITY IN ('UNITED KI1', 'UNITED KI5')
- AND LO_ORDERDATE >= 19971201
- AND LO_ORDERDATE <= 19971231
-GROUP BY C_CITY, S_CITY, YEAR
-ORDER BY YEAR ASC, revenue DESC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql
deleted file mode 100644
index 87b29bf160a..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql
+++ /dev/null
@@ -1,27 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q4.1
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ (LO_ORDERDATE
DIV 10000) AS YEAR,
- C_NATION,
- SUM(LO_REVENUE - LO_SUPPLYCOST) AS profit
-FROM lineorder_flat
-WHERE
- C_REGION = 'AMERICA'
- AND S_REGION = 'AMERICA'
- AND P_MFGR IN ('MFGR#1', 'MFGR#2')
-GROUP BY YEAR, C_NATION
-ORDER BY YEAR ASC, C_NATION ASC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql
deleted file mode 100644
index 8ea28f3f120..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql
+++ /dev/null
@@ -1,33 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q4.2
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ (LO_ORDERDATE
DIV 10000) AS YEAR,
- S_NATION,
- P_CATEGORY,
- SUM(LO_REVENUE - LO_SUPPLYCOST) AS profit
-FROM lineorder_flat
-WHERE
- C_REGION = 'AMERICA'
- AND S_REGION = 'AMERICA'
- AND LO_ORDERDATE >= 19970101
- AND LO_ORDERDATE <= 19981231
- AND P_MFGR IN ('MFGR#1', 'MFGR#2')
-GROUP BY YEAR, S_NATION, P_CATEGORY
-ORDER BY
- YEAR ASC,
- S_NATION ASC,
- P_CATEGORY ASC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql
deleted file mode 100644
index 0f7c7401ab6..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql
+++ /dev/null
@@ -1,29 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
---Q4.3
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ (LO_ORDERDATE
DIV 10000) AS YEAR,
- S_CITY,
- P_BRAND,
- SUM(LO_REVENUE - LO_SUPPLYCOST) AS profit
-FROM lineorder_flat
-WHERE
- S_NATION = 'UNITED STATES'
- AND LO_ORDERDATE >= 19970101
- AND LO_ORDERDATE <= 19981231
- AND P_CATEGORY = 'MFGR#14'
-GROUP BY YEAR, S_CITY, P_BRAND
-ORDER BY YEAR ASC, S_CITY ASC, P_BRAND ASC;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql
deleted file mode 100644
index 50b50bc3683..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql
+++ /dev/null
@@ -1,24 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(lo_extendedprice*lo_discount) AS
-REVENUE
-FROM lineorder, date
-WHERE lo_orderdate = d_datekey
-AND d_year = 1993
-AND lo_discount BETWEEN 1 AND 3
-AND lo_quantity < 25;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql
deleted file mode 100644
index 77c02620167..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql
+++ /dev/null
@@ -1,24 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(lo_extendedprice*lo_discount) AS
-REVENUE
-FROM lineorder, date
-WHERE lo_orderdate = d_datekey
-AND d_yearmonth = 'Jan1994'
-AND lo_discount BETWEEN 4 AND 6
-AND lo_quantity BETWEEN 26 AND 35;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql
deleted file mode 100644
index 0052db0aac3..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql
+++ /dev/null
@@ -1,25 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(lo_extendedprice*lo_discount) AS
-REVENUE
-FROM lineorder, date
-WHERE lo_orderdate = d_datekey
-AND d_weeknuminyear= 6
-AND d_year = 1994
-AND lo_discount BETWEEN 5 AND 7
-AND lo_quantity BETWEEN 26 AND 35;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql
deleted file mode 100644
index a47ec82b517..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql
+++ /dev/null
@@ -1,26 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(lo_revenue), d_year, p_brand
-FROM lineorder, date, part, supplier
-WHERE lo_orderdate = d_datekey
-AND lo_partkey = p_partkey
-AND lo_suppkey = s_suppkey
-AND p_category = 'MFGR#12'
-AND s_region = 'AMERICA'
-GROUP BY d_year, p_brand
-ORDER BY d_year, p_brand;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql
deleted file mode 100644
index 9ab1a95d4d7..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql
+++ /dev/null
@@ -1,27 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(lo_revenue), d_year, p_brand
-FROM lineorder, date, part, supplier
-WHERE lo_orderdate = d_datekey
-AND lo_partkey = p_partkey
-AND lo_suppkey = s_suppkey
-AND p_brand BETWEEN 'MFGR#2221'
-AND 'MFGR#2228'
-AND s_region = 'ASIA'
-GROUP BY d_year, p_brand
-ORDER BY d_year, p_brand;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql
deleted file mode 100644
index b7e6bd78409..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql
+++ /dev/null
@@ -1,26 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */
SUM(lo_revenue), d_year, p_brand
-FROM lineorder, date, part, supplier
-WHERE lo_orderdate = d_datekey
-AND lo_partkey = p_partkey
-AND lo_suppkey = s_suppkey
-AND p_brand = 'MFGR#2239'
-AND s_region = 'EUROPE'
-GROUP BY d_year, p_brand
-ORDER BY d_year, p_brand;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql
deleted file mode 100644
index 85c470b7086..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql
+++ /dev/null
@@ -1,28 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ c_nation,
s_nation, d_year,
-SUM(lo_revenue) AS REVENUE
-FROM customer, lineorder, supplier, date
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_orderdate = d_datekey
-AND c_region = 'ASIA'
-AND s_region = 'ASIA'
-AND d_year >= 1992 AND d_year <= 1997
-GROUP BY c_nation, s_nation, d_year
-ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql
deleted file mode 100644
index cd0b320f87f..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql
+++ /dev/null
@@ -1,28 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ c_city,
s_city, d_year, sum(lo_revenue)
-AS REVENUE
-FROM customer, lineorder, supplier, date
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_orderdate = d_datekey
-AND c_nation = 'UNITED STATES'
-AND s_nation = 'UNITED STATES'
-AND d_year >= 1992 AND d_year <= 1997
-GROUP BY c_city, s_city, d_year
-ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql
deleted file mode 100644
index 89765c02d9c..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql
+++ /dev/null
@@ -1,30 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ c_city,
s_city, d_year, SUM(lo_revenue)
-AS REVENUE
-FROM customer, lineorder, supplier, date
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_orderdate = d_datekey
-AND (c_city='UNITED KI1'
-OR c_city='UNITED KI5')
-AND (s_city='UNITED KI1'
-OR s_city='UNITED KI5')
-AND d_year >= 1992 AND d_year <= 1997
-GROUP BY c_city, s_city, d_year
-ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql
deleted file mode 100644
index 5cef87a3fe3..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql
+++ /dev/null
@@ -1,30 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ c_city,
s_city, d_year, SUM(lo_revenue)
-AS REVENUE
-FROM customer, lineorder, supplier, date
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_orderdate = d_datekey
-AND (c_city='UNITED KI1'
-OR c_city='UNITED KI5')
-AND (s_city='UNITED KI1'
-OR s_city='UNITED KI5')
-AND d_yearmonth = 'Dec1997'
-GROUP BY c_city, s_city, d_year
-ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql
deleted file mode 100644
index 3e0227c2ea9..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql
+++ /dev/null
@@ -1,30 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ d_year,
c_nation,
-SUM(lo_revenue - lo_supplycost) AS PROFIT
-FROM date, customer, supplier, part, lineorder
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_partkey = p_partkey
-AND lo_orderdate = d_datekey
-AND c_region = 'AMERICA'
-AND s_region = 'AMERICA'
-AND (p_mfgr = 'MFGR#1'
-OR p_mfgr = 'MFGR#2')
-GROUP BY d_year, c_nation
-ORDER BY d_year, c_nation;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql
deleted file mode 100644
index 1338e780ae5..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql
+++ /dev/null
@@ -1,31 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ d_year,
s_nation, p_category,
-SUM(lo_revenue - lo_supplycost) AS PROFIT
-FROM date, customer, supplier, part, lineorder
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_partkey = p_partkey
-AND lo_orderdate = d_datekey
-AND c_region = 'AMERICA'
-AND s_region = 'AMERICA'
-AND (d_year = 1997 OR d_year = 1998)
-AND (p_mfgr = 'MFGR#1'
-OR p_mfgr = 'MFGR#2')
-GROUP BY d_year, s_nation, p_category
-ORDER BY d_year, s_nation, p_category;
diff --git a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql
b/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql
deleted file mode 100644
index d8e6f7c42d4..00000000000
--- a/regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql
+++ /dev/null
@@ -1,29 +0,0 @@
--- Licensed to the Apache Software Foundation (ASF) under one
--- or more contributor license agreements. See the NOTICE file
--- distributed with this work for additional information
--- regarding copyright ownership. The ASF licenses this file
--- to you under the Apache License, Version 2.0 (the
--- "License"); you may not use this file except in compliance
--- with the License. You may obtain a copy of the License at
---
--- http://www.apache.org/licenses/LICENSE-2.0
---
--- Unless required by applicable law or agreed to in writing,
--- software distributed under the License is distributed on an
--- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
--- KIND, either express or implied. See the License for the
--- specific language governing permissions and limitations
--- under the License.
-
-SELECT /*+SET_VAR(experimental_enable_pipeline_x_engine=true) */ d_year,
s_city, p_brand,
-SUM(lo_revenue - lo_supplycost) AS PROFIT
-FROM date, customer, supplier, part, lineorder
-WHERE lo_custkey = c_custkey
-AND lo_suppkey = s_suppkey
-AND lo_partkey = p_partkey
-AND lo_orderdate = d_datekey
-AND s_nation = 'UNITED STATES'
-AND (d_year = 1997 OR d_year = 1998)
-AND p_category = 'MFGR#14'
-GROUP BY d_year, s_city, p_brand
-ORDER BY d_year, s_city, p_brand;
diff --git a/regression-test/suites/variant_p0/nested.groovy
b/regression-test/suites/variant_p0/nested.groovy
index a0beed45c69..047de391ca0 100644
--- a/regression-test/suites/variant_p0/nested.groovy
+++ b/regression-test/suites/variant_p0/nested.groovy
@@ -117,7 +117,7 @@
parallel_pipeline_task_num=7,profile_level=1,enable_pipeline_engine=true,enable_
properties("replication_num" = "1", "disable_auto_compaction"
= "false", "enable_unique_key_merge_on_write" = "true",
"variant_enable_flatten_nested" = "true");
"""
sql """insert into var_nested2 select * from var_nested order by k
limit 1024"""
- qt_sql """select
/*+SET_VAR(batch_size=4064,broker_load_batch_size=16352,disable_streaming_preaggregations=true,enable_distinct_streaming_aggregation=true,parallel_pipeline_task_num=1,profile_level=1,enable_pipeline_engine=false,enable_parallel_scan=true,parallel_scan_max_scanners_count=48,parallel_scan_min_rows_per_scanner=16384,enable_fold_constant_by_be=true,enable_rewrite_element_at_to_slot=true,runtime_filter_type=12,enable_parallel_result_sink=false,enable_nereids_planner=
[...]
+ qt_sql """select
/*+SET_VAR(batch_size=4064,broker_load_batch_size=16352,disable_streaming_preaggregations=true,enable_distinct_streaming_aggregation=true,parallel_pipeline_task_num=1,profile_level=1,enable_parallel_scan=true,parallel_scan_max_scanners_count=48,parallel_scan_min_rows_per_scanner=16384,enable_fold_constant_by_be=true,enable_rewrite_element_at_to_slot=true,runtime_filter_type=12,enable_parallel_result_sink=false,enable_nereids_planner=true,rewrite_or_to_in_predica
[...]
qt_sql """select v['nested'] from var_nested2 where k < 10 order by k
limit 10;"""
// 0. nomal explode variant array
order_qt_explode_sql """select count(),cast(vv['xx'] as int) from
var_nested lateral view explode_variant_array(v['nested']) tmp as vv where
vv['xx'] = 10 group by cast(vv['xx'] as int)"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
