File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
src/query/service/src/interpreters Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,7 @@ use std::sync::Arc;
17
17
use common_exception:: ErrorCode ;
18
18
use common_exception:: Result ;
19
19
use common_legacy_planners:: PlanNode ;
20
+ use tracing:: error;
20
21
21
22
use crate :: interpreters:: access:: Accessor ;
22
23
use crate :: interpreters:: DeleteInterpreter ;
@@ -38,7 +39,9 @@ impl InterpreterFactory {
38
39
pub fn get ( ctx : Arc < QueryContext > , plan : PlanNode ) -> Result < Arc < dyn Interpreter > > {
39
40
// Check the access permission.
40
41
let access_checker = Accessor :: create ( ctx. clone ( ) ) ;
41
- access_checker. check ( & plan) ?;
42
+ access_checker
43
+ . check ( & plan)
44
+ . map ( |e| error ! ( "Access.denied(v1): {:?}" , e) ) ?;
42
45
43
46
let inner = Self :: create_interpreter ( ctx. clone ( ) , & plan) ?;
44
47
let query_kind = plan. name ( ) . to_string ( ) ;
Original file line number Diff line number Diff line change 15
15
use std:: sync:: Arc ;
16
16
17
17
use common_exception:: Result ;
18
+ use tracing:: error;
18
19
19
20
use super :: interpreter_share_desc:: DescShareInterpreter ;
20
21
use super :: interpreter_user_stage_drop:: DropUserStageInterpreter ;
@@ -45,7 +46,9 @@ impl InterpreterFactoryV2 {
45
46
pub fn get ( ctx : Arc < QueryContext > , plan : & Plan ) -> Result < InterpreterPtr > {
46
47
// Check the access permission.
47
48
let access_checker = Accessor :: create ( ctx. clone ( ) ) ;
48
- access_checker. check_new ( plan) ?;
49
+ access_checker
50
+ . check_new ( plan)
51
+ . map ( |e| error ! ( "Access.denied(v2): {:?}" , e) ) ?;
49
52
50
53
let inner = InterpreterFactoryV2 :: create_interpreter ( ctx. clone ( ) , plan) ?;
51
54
You can’t perform that action at this time.
0 commit comments