File tree Expand file tree Collapse file tree 1 file changed +0
-15
lines changed
src/query/service/src/pipelines/processors/transforms/hash_join Expand file tree Collapse file tree 1 file changed +0
-15
lines changed Original file line number Diff line number Diff line change @@ -106,7 +106,6 @@ pub struct TransformHashJoinBuild {
106106 processor_memory_threshold : usize ,
107107
108108 step : Step ,
109- step_logs : Vec < Step > ,
110109}
111110
112111impl TransformHashJoinBuild {
@@ -152,7 +151,6 @@ impl TransformHashJoinBuild {
152151 global_memory_threshold,
153152 processor_memory_threshold,
154153 step : Step :: Sync ( SyncStep :: Collect ) ,
155- step_logs : vec ! [ Step :: Sync ( SyncStep :: Collect ) ] ,
156154 } ) )
157155 }
158156
@@ -166,7 +164,6 @@ impl TransformHashJoinBuild {
166164 }
167165 } ;
168166 self . step = step;
169- self . step_logs . push ( step) ;
170167 Ok ( event)
171168 }
172169
@@ -331,18 +328,6 @@ impl Processor for TransformHashJoinBuild {
331328 }
332329 Ok ( ( ) )
333330 }
334-
335- fn details_status ( & self ) -> Option < String > {
336- #[ derive( Debug ) ]
337- #[ allow( dead_code) ]
338- struct Display {
339- step_logs : Vec < Step > ,
340- }
341-
342- Some ( format ! ( "{:?}" , Display {
343- step_logs: self . step_logs. clone( ) ,
344- } ) )
345- }
346331}
347332
348333impl TransformHashJoinBuild {
You can’t perform that action at this time.
0 commit comments