From d1fcb745cc5649ec701ac5b6b9e55ab56dac75f1 Mon Sep 17 00:00:00 2001 From: Xinyi Zou Date: Thu, 2 Nov 2023 09:49:44 +0800 Subject: [PATCH] 15 --- be/src/runtime/result_buffer_mgr.h | 2 +- fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/be/src/runtime/result_buffer_mgr.h b/be/src/runtime/result_buffer_mgr.h index 8235b6cc15287a6..4e016adc1c693e1 100644 --- a/be/src/runtime/result_buffer_mgr.h +++ b/be/src/runtime/result_buffer_mgr.h @@ -65,7 +65,7 @@ class ResultBufferMgr { // fetch data result to Arrow Flight Server Status fetch_arrow_data(const TUniqueId& finst_id, std::shared_ptr* result); - void register_arrow_schema(const TUniqueId& query_id, + static void register_arrow_schema(const TUniqueId& query_id, const std::shared_ptr& arrow_schema); std::shared_ptr find_arrow_schema(const TUniqueId& query_id); diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index 08c7ee03254afb8..b7cc96a67a3c1a7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -1410,7 +1410,7 @@ private void handleQueryStmt() throws Exception { boolean isOutfileQuery = queryStmt.hasOutFileClause(); // Sql and PartitionCache - CacheAnalyzer cacheAnalyzer = new CacheAnalyzer(context, parsedStmt, planner);\ + CacheAnalyzer cacheAnalyzer = new CacheAnalyzer(context, parsedStmt, planner); // TODO support arrow flight sql if (context.getConnectType().equals(ConnectType.MYSQL) && cacheAnalyzer.enableCache() && !isOutfileQuery && context.getSessionVariable().getSqlSelectLimit() < 0