chore(cubestore): Upgrade DF: fix ordering issues

Author: paveltiunov

rust/cubestore/cubestore/src/queryplanner/pretty_printers.rs

@@ -37,6 +37,7 @@ use datafusion::physical_plan::projection::ProjectionExec;
 use datafusion::physical_plan::repartition::RepartitionExec;
 use datafusion::physical_plan::sorts::sort::SortExec;
 use datafusion::physical_plan::union::UnionExec;
+use crate::queryplanner::providers::InfoSchemaQueryCacheTableProvider;
 
 #[derive(Default, Clone, Copy)]
 pub struct PPOptions {
@@ -305,6 +306,8 @@ fn pp_source(t: Arc<dyn TableProvider>) -> String {
         format!("InlineTableProvider(data: {} rows)", t.get_data().len())
     } else if let Some(t) = t.as_any().downcast_ref::<InfoSchemaTableProvider>() {
         format!("InfoSchemaTableProvider(table: {:?})", t.table)
+    } else if let Some(_) = t.as_any().downcast_ref::<InfoSchemaQueryCacheTableProvider>() {
+        "InfoSchemaQueryCacheTableProvider".to_string()
     } else {
         panic!("unknown table provider");
     }

rust/cubestore/cubestore/src/queryplanner/query_executor.rs

@@ -1523,8 +1523,22 @@ impl ExecutionPlan for ClusterSendExec {
         &self.properties
     }
 
+    fn required_input_ordering(&self) -> Vec<Option<LexRequirement>> {
+        let input_ordering = self.input_for_optimizations.required_input_ordering();
+        if !input_ordering.is_empty() {
+            vec![input_ordering[0].clone()]
+        } else {
+            vec![None]
+        }
+    }
+
     fn maintains_input_order(&self) -> Vec<bool> {
-        vec![true; self.children().len()]
+        let maintains_input_order = self.input_for_optimizations.maintains_input_order();
+        if !maintains_input_order.is_empty() {
+            vec![maintains_input_order[0]]
+        } else {
+            vec![false]
+        }
     }
 }