Skip to content

Commit c1a47e3

Browse files
abyss7abyss7
authored
Merge c1733e7 into 6b9001c 
2 parents 6b9001c + c1733e7 commit c1a47e3

File tree

556 files changed

+1321
-1342
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

556 files changed

+1321
-1342
lines changed

‎ydb/core/kqp/opt/peephole/kqp_opt_peephole.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -283,13 +283,13 @@ bool CanPropagateWideBlockThroughChannel(
283283
return false;
284284
}
285285

286-
auto outputItemType = program.Lambda().Ref().GetTypeAnn()->Cast<TStreamExprType>()->GetItemType();
287-
if (IsWideBlockType(*outputItemType)) {
288-
// output is already wide block
286+
if (!stageSettings.WideChannels) {
289287
return false;
290288
}
291289

292-
if (!stageSettings.WideChannels) {
290+
auto outputItemType = program.Lambda().Ref().GetTypeAnn()->Cast<TStreamExprType>()->GetItemType();
291+
if (IsWideBlockType(*outputItemType)) {
292+
// output is already wide block
293293
return false;
294294
}
295295

‎ydb/core/kqp/ut/query/kqp_limits_ut.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1010,7 +1010,7 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
10101010

10111011
UNIT_ASSERT_VALUES_EQUAL(plan["Plan"]["Node Type"].GetStringSafe(), "Query");
10121012
UNIT_ASSERT_VALUES_EQUAL(plan["Plan"]["Plans"][0]["Node Type"].GetStringSafe(), "ResultSet");
1013-
UNIT_ASSERT_VALUES_EQUAL(plan["Plan"]["Plans"][0]["Plans"][0]["Node Type"].GetStringSafe(), "Collect");
1013+
UNIT_ASSERT_VALUES_EQUAL(plan["Plan"]["Plans"][0]["Plans"][0]["Node Type"].GetStringSafe(), "Stage");
10141014
UNIT_ASSERT_VALUES_EQUAL(plan["Plan"]["Plans"][0]["Plans"][0]["Plans"][0]["Node Type"].GetStringSafe(), "Merge");
10151015
UNIT_ASSERT_VALUES_EQUAL(plan["Plan"]["Plans"][0]["Plans"][0]["Plans"][0]["SortColumns"].GetArraySafe()[0], "Key (Asc)");
10161016

‎ydb/core/protos/table_service_config.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -289,7 +289,7 @@ message TTableServiceConfig {
289289
BLOCK_CHANNELS_AUTO = 1;
290290
BLOCK_CHANNELS_FORCE = 2;
291291
}
292-
optional EBlockChannelsMode BlockChannelsMode = 61 [default = BLOCK_CHANNELS_SCALAR];
292+
optional EBlockChannelsMode BlockChannelsMode = 61 [default = BLOCK_CHANNELS_AUTO];
293293

294294
optional uint64 QueryReplayCacheUploadTTLSec = 62 [default = 36000];
295295

‎ydb/tests/functional/canonical/canondata/test_sql.TestCanonicalFolder1.test_case_join_group_by_lookup.script-script_/join_group_by_lookup.script.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,8 +73,8 @@
7373
"Operators": [
7474
{
7575
"Inputs": [],
76-
"Iterator": "precompute_0_0",
77-
"Name": "Iterator"
76+
"Name": "ToFlow",
77+
"ToFlow": "precompute_0_0"
7878
}
7979
],
8080
"PlanNodeId": 16
@@ -87,7 +87,7 @@
8787
"PlanNodeType": "Connection",
8888
"Plans": [
8989
{
90-
"Node Type": "Collect",
90+
"Node Type": "Stage",
9191
"PlanNodeId": 14,
9292
"Plans": [
9393
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_coalesce-and-join.test_/query_1.plan

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@
6767
"Operators": [
6868
{
6969
"Inputs": [],
70-
"Iterator": "precompute_2_0",
71-
"Name": "Iterator"
70+
"Name": "ToFlow",
71+
"ToFlow": "precompute_2_0"
7272
}
7373
],
7474
"PlanNodeId": 28
@@ -81,7 +81,7 @@
8181
"PlanNodeType": "Connection",
8282
"Plans": [
8383
{
84-
"Node Type": "Collect",
84+
"Node Type": "Stage",
8585
"PlanNodeId": 26,
8686
"Plans": [
8787
{
@@ -207,8 +207,8 @@
207207
"Operators": [
208208
{
209209
"Inputs": [],
210-
"Iterator": "precompute_0_0",
211-
"Name": "Iterator"
210+
"Name": "ToFlow",
211+
"ToFlow": "precompute_0_0"
212212
}
213213
],
214214
"PlanNodeId": 14
@@ -221,7 +221,7 @@
221221
"PlanNodeType": "Connection",
222222
"Plans": [
223223
{
224-
"Node Type": "Collect",
224+
"Node Type": "Stage",
225225
"PlanNodeId": 12,
226226
"Plans": [
227227
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_coalesce-and-join.test_/query_2.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@
6767
"Operators": [
6868
{
6969
"Inputs": [],
70-
"Iterator": "precompute_0_0",
71-
"Name": "Iterator"
70+
"Name": "ToFlow",
71+
"ToFlow": "precompute_0_0"
7272
}
7373
],
7474
"PlanNodeId": 14
@@ -81,7 +81,7 @@
8181
"PlanNodeType": "Connection",
8282
"Plans": [
8383
{
84-
"Node Type": "Collect",
84+
"Node Type": "Stage",
8585
"PlanNodeId": 12,
8686
"Plans": [
8787
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_coalesce-and-join.test_/query_3.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@
6767
"Operators": [
6868
{
6969
"Inputs": [],
70-
"Iterator": "precompute_0_0",
71-
"Name": "Iterator"
70+
"Name": "ToFlow",
71+
"ToFlow": "precompute_0_0"
7272
}
7373
],
7474
"PlanNodeId": 14
@@ -81,7 +81,7 @@
8181
"PlanNodeType": "Connection",
8282
"Plans": [
8383
{
84-
"Node Type": "Collect",
84+
"Node Type": "Stage",
8585
"PlanNodeId": 12,
8686
"Plans": [
8787
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_coalesce-and-join.test_/query_4.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@
6767
"Operators": [
6868
{
6969
"Inputs": [],
70-
"Iterator": "precompute_0_0",
71-
"Name": "Iterator"
70+
"Name": "ToFlow",
71+
"ToFlow": "precompute_0_0"
7272
}
7373
],
7474
"PlanNodeId": 14
@@ -81,7 +81,7 @@
8181
"PlanNodeType": "Connection",
8282
"Plans": [
8383
{
84-
"Node Type": "Collect",
84+
"Node Type": "Stage",
8585
"PlanNodeId": 12,
8686
"Plans": [
8787
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_coalesce-and-join.test_/query_5.plan

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@
6262
"PlanNodeType": "Connection",
6363
"Plans": [
6464
{
65-
"Node Type": "Collect",
65+
"Node Type": "Stage",
6666
"PlanNodeId": 4,
6767
"Plans": [
6868
{
@@ -111,7 +111,7 @@
111111
"PlanNodeType": "Connection",
112112
"Plans": [
113113
{
114-
"Node Type": "Collect",
114+
"Node Type": "Stage",
115115
"PlanNodeId": 7,
116116
"Plans": [
117117
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_join-group-by-with-null.test_/query_2.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@
9191
"Operators": [
9292
{
9393
"Inputs": [],
94-
"Iterator": "precompute_0_0",
95-
"Name": "Iterator"
94+
"Name": "ToFlow",
95+
"ToFlow": "precompute_0_0"
9696
}
9797
],
9898
"PlanNodeId": 14
@@ -105,7 +105,7 @@
105105
"PlanNodeType": "Connection",
106106
"Plans": [
107107
{
108-
"Node Type": "Collect",
108+
"Node Type": "Stage",
109109
"PlanNodeId": 12,
110110
"Plans": [
111111
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_join-group-by-with-null.test_/query_3.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@
9191
"Operators": [
9292
{
9393
"Inputs": [],
94-
"Iterator": "precompute_0_0",
95-
"Name": "Iterator"
94+
"Name": "ToFlow",
95+
"ToFlow": "precompute_0_0"
9696
}
9797
],
9898
"PlanNodeId": 14
@@ -105,7 +105,7 @@
105105
"PlanNodeType": "Connection",
106106
"Plans": [
107107
{
108-
"Node Type": "Collect",
108+
"Node Type": "Stage",
109109
"PlanNodeId": 12,
110110
"Plans": [
111111
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_join-group-by-with-null.test_/query_4.plan

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@
123123
"PlanNodeType": "Connection",
124124
"Plans": [
125125
{
126-
"Node Type": "Collect",
126+
"Node Type": "Stage",
127127
"PlanNodeId": 6,
128128
"Plans": [
129129
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_join-group-by-with-null.test_/query_5.plan

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@
132132
"PlanNodeType": "Connection",
133133
"Plans": [
134134
{
135-
"Node Type": "Collect",
135+
"Node Type": "Stage",
136136
"PlanNodeId": 4,
137137
"Plans": [
138138
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_join0.test_/query_1.plan

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@
6262
"PlanNodeType": "Connection",
6363
"Plans": [
6464
{
65-
"Node Type": "Collect",
65+
"Node Type": "Stage",
6666
"PlanNodeId": 4,
6767
"Plans": [
6868
{
@@ -135,7 +135,7 @@
135135
"PlanNodeType": "Connection",
136136
"Plans": [
137137
{
138-
"Node Type": "Collect",
138+
"Node Type": "Stage",
139139
"PlanNodeId": 7,
140140
"Plans": [
141141
{

‎ydb/tests/functional/suite_tests/canondata/test_postgres.TestPGSQL.test_sql_suite_plan-jointest_join0.test_/query_10.plan

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@
7979
"PlanNodeType": "Connection",
8080
"Plans": [
8181
{
82-
"Node Type": "Collect",
82+
"Node Type": "Stage",
8383
"PlanNodeId": 4,
8484
"Plans": [
8585
{
@@ -88,7 +88,7 @@
8888
"PlanNodeType": "Connection",
8989
"Plans": [
9090
{
91-
"Node Type": "Collect",
91+
"Node Type": "Stage",
9292
"PlanNodeId": 2,
9393
"Plans": [
9494
{
@@ -130,7 +130,7 @@
130130
"PlanNodeType": "Connection",
131131
"Plans": [
132132
{
133-
"Node Type": "Collect",
133+
"Node Type": "Stage",
134134
"PlanNodeId": 7,
135135
"Plans": [
136136
{

0 commit comments

Comments
 (0)