1

apache · Mar 30, 2024 · d109878 · d109878
1 parent 2b94cd1
commit d109878
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/be/src/service/internal_service.cpp b/be/src/service/internal_service.cpp
@@ -690,8 +690,7 @@ void PInternalService::fetch_table_schema(google::protobuf::RpcController* contr
             std::vector<SlotDescriptor*> file_slots;
             reader = vectorized::AvroJNIReader::create_unique(profile.get(), params, range,
                                                               file_slots);
-            static_cast<void>(
-                    ((vectorized::AvroJNIReader*)(reader.get()))->init_fetch_table_schema_reader());
+            st = ((vectorized::AvroJNIReader*)(reader.get()))->init_fetch_table_schema_reader();
             break;
         }
         default:
@@ -700,6 +699,11 @@ void PInternalService::fetch_table_schema(google::protobuf::RpcController* contr
             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);

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
@@ -232,6 +232,7 @@ public void executeQuery(MysqlCommand mysqlCommand, String originStmt) throws Ex
                 // Parse sql failed, audit it and return
                 handleQueryException(e, convertedStmt, null, null);
                 return;
+            } catch (ParseEx)
             } catch (Exception e) {
                 // TODO: We should catch all exception here until we support all query syntax.
                 if (LOG.isDebugEnabled()) {