Skip to content

Commit fe491cb

Browse files
authored
chore(query): max_decoding_message_size (#14687)
* chore(query): max_decoding_message_size * chore(query): max_decoding_message_size * chore(query): max_decoding_message_size * chore(query): max_decoding_message_size * chore(query): max_decoding_message_size
1 parent 2b987e7 commit fe491cb

File tree

3 files changed

+8
-5
lines changed

3 files changed

+8
-5
lines changed

src/query/expression/src/utils/udf_client.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@ use crate::DataSchema;
3535
const UDF_TCP_KEEP_ALIVE_SEC: u64 = 30;
3636
const UDF_HTTP2_KEEP_ALIVE_INTERVAL_SEC: u64 = 60;
3737
const UDF_KEEP_ALIVE_TIMEOUT_SEC: u64 = 20;
38+
const MAX_DECODING_MESSAGE_SIZE: usize = 16 * 1024 * 1024 * 1024;
3839

3940
#[derive(Debug, Clone)]
4041
pub struct UDFFlightClient {
@@ -65,7 +66,9 @@ impl UDFFlightClient {
6566
ErrorCode::UDFServerConnectError(format!(
6667
"Cannot connect to UDF Server {addr}: {err}"
6768
))
68-
})?;
69+
})?
70+
.max_decoding_message_size(MAX_DECODING_MESSAGE_SIZE);
71+
6972
Ok(UDFFlightClient { inner })
7073
}
7174

src/query/settings/src/settings_default.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -131,13 +131,13 @@ impl DefaultSettings {
131131
value: UserSettingValue::UInt64(65536),
132132
desc: "Sets the maximum byte size of a single data block that can be read.",
133133
mode: SettingMode::Both,
134-
range: None,
134+
range: Some(SettingRange::Numeric(1..=u64::MAX)),
135135
}),
136136
("parquet_max_block_size", DefaultSettingValue {
137137
value: UserSettingValue::UInt64(8192),
138138
desc: "Max block size for parquet reader",
139139
mode: SettingMode::Both,
140-
range: None,
140+
range: Some(SettingRange::Numeric(1..=u64::MAX)),
141141
}),
142142
("max_threads", DefaultSettingValue {
143143
value: UserSettingValue::UInt64(num_cpus),

tests/sqllogictests/suites/base/06_show/06_0003_show_settings.test

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,12 +31,12 @@ SHOW SETTINGS LIKE 'enable%'
3131
query TT
3232
SHOW SETTINGS LIKE 'max%' LIMIT 1
3333
----
34-
max_block_size 65536 65536 None DEFAULT Sets the maximum byte size of a single data block that can be read. UInt64
34+
max_block_size 65536 65536 [1, 18446744073709551615] DEFAULT Sets the maximum byte size of a single data block that can be read. UInt64
3535

3636
query TT
3737
SHOW SETTINGS WHERE name='max_block_size' LIMIT 1
3838
----
39-
max_block_size 65536 65536 None DEFAULT Sets the maximum byte size of a single data block that can be read. UInt64
39+
max_block_size 65536 65536 [1, 18446744073709551615] DEFAULT Sets the maximum byte size of a single data block that can be read. UInt64
4040

4141
statement error
4242
SHOW SETTINGS ilike 'ff%' LIMIT 1

0 commit comments

Comments
 (0)