File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
src/query/service/src/interpreters Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -267,7 +267,11 @@ impl ReclusterTableInterpreter {
267267 acc
268268 } ,
269269 ) ;
270-
270+
271+ let query_str = self . ctx . get_query_str ( ) ;
272+ let write_progress = self . ctx . get_write_progress ( ) ;
273+ let write_progress_value = write_progress. as_ref ( ) . get_values ( ) ;
274+
271275 let subquery_executor = Arc :: new ( ServiceQueryExecutor :: new (
272276 QueryContext :: create_from ( self . ctx . as_ref ( ) ) ,
273277 ) ) ;
@@ -349,9 +353,6 @@ impl ReclusterTableInterpreter {
349353 . unwrap_or_default ( ) ;
350354 let ( stmt, _) = parse_sql ( & tokens, sql_dialect) ?;
351355
352- let query_str = self . ctx . get_query_str ( ) ;
353- let write_progress = self . ctx . get_write_progress ( ) ;
354- let write_progress_value = write_progress. as_ref ( ) . get_values ( ) ;
355356 let mut planner =
356357 Planner :: new_with_query_executor ( self . ctx . clone ( ) , subquery_executor) ;
357358 let plan = planner. plan_stmt ( & stmt, false ) . await ?;
You can’t perform that action at this time.
0 commit comments