[doris] 23/33: [fix](file_reader) bad_typeid when reading csv&json files #18400

[morningman]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch doris-for-zhongjin
in repository https://gitbox.apache.org/repos/asf/doris.git

commit f33b518a733c365e3d8154ef6ae5c9182677ff44
Author: morningman <morning...@163.com>
AuthorDate: Wed Apr 5 19:29:36 2023 +0800

    [fix](file_reader) bad_typeid when reading csv&json files #18400
---
 be/src/vec/exec/format/csv/csv_reader.cpp       | 2 +-
 be/src/vec/exec/format/json/new_json_reader.cpp | 2 +-
 be/src/vec/exec/format/orc/vorc_reader.h        | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/be/src/vec/exec/format/csv/csv_reader.cpp 
b/be/src/vec/exec/format/csv/csv_reader.cpp
index 7f114167ea..ee15846cde 100644
--- a/be/src/vec/exec/format/csv/csv_reader.cpp
+++ b/be/src/vec/exec/format/csv/csv_reader.cpp
@@ -145,7 +145,7 @@ Status CsvReader::init_reader(bool is_load) {
         io::FileCachePolicy cache_policy = 
FileFactory::get_cache_policy(_state);
         RETURN_IF_ERROR(FileFactory::create_file_reader(_profile, 
_system_properties,
                                                         _file_description, 
&_file_system,
-                                                        &_file_reader, 
cache_policy));
+                                                        &csv_file_reader, 
cache_policy));
     }
     if (typeid_cast<io::S3FileReader*>(csv_file_reader.get()) != nullptr ||
         typeid_cast<io::BrokerFileReader*>(csv_file_reader.get()) != nullptr) {
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 cea79dad75..0f6fc0030e 100644
--- a/be/src/vec/exec/format/json/new_json_reader.cpp
+++ b/be/src/vec/exec/format/json/new_json_reader.cpp
@@ -342,7 +342,7 @@ Status NewJsonReader::_open_file_reader() {
         io::FileCachePolicy cache_policy = 
FileFactory::get_cache_policy(_state);
         RETURN_IF_ERROR(FileFactory::create_file_reader(_profile, 
_system_properties,
                                                         _file_description, 
&_file_system,
-                                                        &_file_reader, 
cache_policy));
+                                                        &json_file_reader, 
cache_policy));
     }
     if (typeid_cast<io::S3FileReader*>(json_file_reader.get()) != nullptr ||
         typeid_cast<io::BrokerFileReader*>(json_file_reader.get()) != nullptr) 
{
diff --git a/be/src/vec/exec/format/orc/vorc_reader.h 
b/be/src/vec/exec/format/orc/vorc_reader.h
index 5430922833..6e520dce15 100644
--- a/be/src/vec/exec/format/orc/vorc_reader.h
+++ b/be/src/vec/exec/format/orc/vorc_reader.h
@@ -247,8 +247,8 @@ private:
     void _collect_profile_on_close();
 
 private:
-    RuntimeProfile* _profile;
-    RuntimeState* _state;
+    RuntimeProfile* _profile = nullptr;
+    RuntimeState* _state = nullptr;
     const TFileScanRangeParams& _scan_params;
     const TFileRangeDesc& _scan_range;
     FileSystemProperties _system_properties;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org