diff --git a/rust/cubestore/Cargo.lock b/rust/cubestore/Cargo.lock
index a2c007a67309e..acacde98afa77 100644
--- a/rust/cubestore/Cargo.lock
+++ b/rust/cubestore/Cargo.lock
@@ -160,7 +160,7 @@ checksum = "23b62fc65de8e4e7f52534fb52b0f3ed04746ae267519eef2a83941e8085068b"
 [[package]]
 name = "arrow"
 version = "5.0.0"
-source = "git+https://github.com/cube-js/arrow-rs.git?branch=cube#1963799bd9fd1de3948eba3fce11ddb9c1392d7c"
+source = "git+https://github.com/cube-js/arrow-rs.git?branch=cube#ea7d11979acb8e1d968c235e24296c3800a4b9ff"
 dependencies = [
  "bitflags 1.3.2",
  "chrono",
@@ -1324,7 +1324,7 @@ checksum = "c2e66c9d817f1720209181c316d28635c050fa304f9c79e47a520882661b7308"
 [[package]]
 name = "datafusion"
 version = "4.0.0-SNAPSHOT"
-source = "git+https://github.com/cube-js/arrow-datafusion?branch=cube#c29478ed9678ad1dcae7508dc0195fb94a689e6c"
+source = "git+https://github.com/cube-js/arrow-datafusion?branch=cube#fa95bd33d5a70792b8e7fdeb9afbfc77fb3c317b"
 dependencies = [
  "ahash",
  "arrow",
@@ -3321,7 +3321,7 @@ dependencies = [
 [[package]]
 name = "parquet"
 version = "5.0.0"
-source = "git+https://github.com/cube-js/arrow-rs.git?branch=cube#1963799bd9fd1de3948eba3fce11ddb9c1392d7c"
+source = "git+https://github.com/cube-js/arrow-rs.git?branch=cube#ea7d11979acb8e1d968c235e24296c3800a4b9ff"
 dependencies = [
  "aes-gcm",
  "arrow",
diff --git a/rust/cubestore/cubestore-sql-tests/src/tests.rs b/rust/cubestore/cubestore-sql-tests/src/tests.rs
index bff0c3b276583..271638dc2e397 100644
--- a/rust/cubestore/cubestore-sql-tests/src/tests.rs
+++ b/rust/cubestore/cubestore-sql-tests/src/tests.rs
@@ -3144,14 +3144,14 @@ async fn planning_inplace_aggregate2(service: Box<dyn SqlClient>) {
         pp_phys_plan_ext(p.router.as_ref(), &verbose),
         "Projection, [url, SUM(Data.hits)@1:hits]\
            \n  AggregateTopK, limit: 10, sortBy: [2 desc null last]\
-           \n    ClusterSend, partitions: [[1, 2]]"
+           \n    ClusterSend, partitions: [[1, 2]], sort_order: [1]"
     );
     assert_eq!(
         pp_phys_plan_ext(p.worker.as_ref(), &verbose),
         "Projection, [url, SUM(Data.hits)@1:hits]\
            \n  AggregateTopK, limit: 10, sortBy: [2 desc null last]\
-           \n    Worker\
-           \n      Sort, by: [SUM(hits)@1 desc nulls last]\
+           \n    Worker, sort_order: [1]\
+           \n      Sort, by: [SUM(hits)@1 desc nulls last], sort_order: [1]\
            \n        FullInplaceAggregate, sort_order: [0]\
            \n          MergeSort, single_vals: [0, 1], sort_order: [0, 1, 2]\
            \n            Union, single_vals: [0, 1], sort_order: [0, 1, 2]\