This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new fee37ff0705 [fix](avro) avoid BE crash if avro scanner's dependency
jars is mssing #33031 (#33090)
fee37ff0705 is described below
commit fee37ff0705672a3e042fa3e4ac0ee2375084977
Author: Mingyu Chen <[email protected]>
AuthorDate: Mon Apr 1 13:51:54 2024 +0800
[fix](avro) avoid BE crash if avro scanner's dependency jars is mssing
#33031 (#33090)
bp #33031
---
be/src/service/internal_service.cpp | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/be/src/service/internal_service.cpp
b/be/src/service/internal_service.cpp
index 2fd4310c4bc..6d19a278a68 100644
--- a/be/src/service/internal_service.cpp
+++ b/be/src/service/internal_service.cpp
@@ -623,7 +623,7 @@ void
PInternalServiceImpl::fetch_table_schema(google::protobuf::RpcController* c
std::vector<SlotDescriptor*> file_slots;
reader = vectorized::AvroJNIReader::create_unique(profile.get(),
params, range,
file_slots);
-
((vectorized::AvroJNIReader*)(reader.get()))->init_fetch_table_schema_reader();
+ st =
((vectorized::AvroJNIReader*)(reader.get()))->init_fetch_table_schema_reader();
break;
}
default:
@@ -632,6 +632,11 @@ void
PInternalServiceImpl::fetch_table_schema(google::protobuf::RpcController* c
st.to_protobuf(result->mutable_status());
return;
}
+ if (!st.ok()) {
+ LOG(WARNING) << "failed to init reader, errmsg=" << st;
+ st.to_protobuf(result->mutable_status());
+ return;
+ }
std::vector<std::string> col_names;
std::vector<TypeDescriptor> col_types;
st = reader->get_parsed_schema(&col_names, &col_types);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
