This is an automated email from the ASF dual-hosted git repository.
yangzhg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new f8bb8c7829 [fix](broker) fix be core dump caused by broker load
(#15390)
f8bb8c7829 is described below
commit f8bb8c7829a19ecf788062ce9e89f88fb4bf0f19
Author: luozenglin <37725793+luozeng...@users.noreply.github.com>
AuthorDate: Wed Dec 28 10:57:41 2022 +0800
[fix](broker) fix be core dump caused by broker load (#15390)
* [fix](broker) fix be core dump caused by broker load
---
be/src/vec/exec/format/csv/csv_reader.cpp | 4 ++++
be/src/vec/exec/format/json/new_json_reader.cpp | 4 ++++
be/src/vec/exec/format/orc/vorc_reader.cpp | 4 ++++
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 4 ++++
4 files changed, 16 insertions(+)
diff --git a/be/src/vec/exec/format/csv/csv_reader.cpp
b/be/src/vec/exec/format/csv/csv_reader.cpp
index 5a7a05ba0a..5e3a975341 100644
--- a/be/src/vec/exec/format/csv/csv_reader.cpp
+++ b/be/src/vec/exec/format/csv/csv_reader.cpp
@@ -109,6 +109,10 @@ Status CsvReader::init_reader(bool is_load) {
system_properties.system_type = _params.file_type;
system_properties.properties = _params.properties;
system_properties.hdfs_params = _params.hdfs_params;
+ if (_params.__isset.broker_addresses) {
+
system_properties.broker_addresses.assign(_params.broker_addresses.begin(),
+
_params.broker_addresses.end());
+ }
FileDescription file_description;
file_description.path = _range.path;
diff --git a/be/src/vec/exec/format/json/new_json_reader.cpp
b/be/src/vec/exec/format/json/new_json_reader.cpp
index 13e86b1ba9..932a792736 100644
--- a/be/src/vec/exec/format/json/new_json_reader.cpp
+++ b/be/src/vec/exec/format/json/new_json_reader.cpp
@@ -291,6 +291,10 @@ Status NewJsonReader::_open_file_reader() {
system_properties.system_type = _params.file_type;
system_properties.properties = _params.properties;
system_properties.hdfs_params = _params.hdfs_params;
+ if (_params.__isset.broker_addresses) {
+
system_properties.broker_addresses.assign(_params.broker_addresses.begin(),
+
_params.broker_addresses.end());
+ }
FileDescription file_description;
file_description.path = _range.path;
diff --git a/be/src/vec/exec/format/orc/vorc_reader.cpp
b/be/src/vec/exec/format/orc/vorc_reader.cpp
index c6867b0d83..0d4fac98f8 100644
--- a/be/src/vec/exec/format/orc/vorc_reader.cpp
+++ b/be/src/vec/exec/format/orc/vorc_reader.cpp
@@ -143,6 +143,10 @@ Status OrcReader::init_reader(
system_properties.system_type = _scan_params.file_type;
system_properties.properties = _scan_params.properties;
system_properties.hdfs_params = _scan_params.hdfs_params;
+ if (_scan_params.__isset.broker_addresses) {
+
system_properties.broker_addresses.assign(_scan_params.broker_addresses.begin(),
+
_scan_params.broker_addresses.end());
+ }
FileDescription file_description;
file_description.path = _scan_range.path;
diff --git a/be/src/vec/exec/format/parquet/vparquet_reader.cpp
b/be/src/vec/exec/format/parquet/vparquet_reader.cpp
index ecf4d23259..e0af528edf 100644
--- a/be/src/vec/exec/format/parquet/vparquet_reader.cpp
+++ b/be/src/vec/exec/format/parquet/vparquet_reader.cpp
@@ -140,6 +140,10 @@ Status ParquetReader::_open_file() {
system_properties.system_type = _scan_params.file_type;
system_properties.properties = _scan_params.properties;
system_properties.hdfs_params = _scan_params.hdfs_params;
+ if (_scan_params.__isset.broker_addresses) {
+
system_properties.broker_addresses.assign(_scan_params.broker_addresses.begin(),
+
_scan_params.broker_addresses.end());
+ }
FileDescription file_description;
file_description.path = _scan_range.path;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
