File tree Expand file tree Collapse file tree
ballista/core/src/execution_plans Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -693,7 +693,6 @@ impl ShuffleWriterExec {
693693 & schema,
694694 & storage,
695695 & write_metrics,
696- now,
697696 file_ext,
698697 )
699698 . await
@@ -711,7 +710,6 @@ impl ShuffleWriterExec {
711710 & schema,
712711 & storage,
713712 & write_metrics,
714- now,
715713 file_ext,
716714 )
717715 . await
@@ -746,7 +744,6 @@ impl ShuffleWriterExec {
746744 schema : & SchemaRef ,
747745 storage : & crate :: shuffle_storage:: ObjectStoreShuffleStorage ,
748746 write_metrics : & ShuffleWriteMetrics ,
749- _now : Instant ,
750747 file_ext : & str ,
751748 ) -> Result < Vec < ShuffleWritePartition > > {
752749 struct ObjectStoreWriteTracker {
@@ -882,7 +879,6 @@ impl ShuffleWriterExec {
882879 schema : & SchemaRef ,
883880 storage : & crate :: shuffle_storage:: ObjectStoreShuffleStorage ,
884881 write_metrics : & ShuffleWriteMetrics ,
885- _now : Instant ,
886882 file_ext : & str ,
887883 ) -> Result < Vec < ShuffleWritePartition > > {
888884 use vortex_array:: arrow:: FromArrowArray ;
You can’t perform that action at this time.
0 commit comments