[GitHub] [arrow] andygrove commented on a change in pull request #7951: ARROW-9716: [Rust] [DataFusion] Implement limit on concurrent threads in MergeExec

andygrove commented on a change in pull request #7951: URL: https://github.com/apache/arrow/pull/7951#discussion_r470603772 ## File path: rust/datafusion/src/execution/context.rs ## @@ -62,10 +62,31 @@ use crate::sql::{ }; use crate::table::Table; +/// Configuration options

[GitHub] [arrow] andygrove commented on a change in pull request #7951: ARROW-9716: [Rust] [DataFusion] Implement limit on concurrent threads in MergeExec

andygrove commented on a change in pull request #7951: URL: https://github.com/apache/arrow/pull/7951#discussion_r470602921 ## File path: rust/datafusion/src/execution/physical_plan/merge.rs ## @@ -64,33 +75,51 @@ struct MergePartition { schema: SchemaRef, /// Input p

[GitHub] [arrow] andygrove commented on a change in pull request #7951: ARROW-9716: [Rust] [DataFusion] Implement limit on concurrent threads in MergeExec

andygrove commented on a change in pull request #7951: URL: https://github.com/apache/arrow/pull/7951#discussion_r470602850 ## File path: rust/datafusion/src/execution/context.rs ## @@ -62,10 +62,31 @@ use crate::sql::{ }; use crate::table::Table; +/// Configuration options

[GitHub] [arrow] andygrove commented on a change in pull request #7951: ARROW-9716: [Rust] [DataFusion] Implement limit on concurrent threads in MergeExec

andygrove commented on a change in pull request #7951: URL: https://github.com/apache/arrow/pull/7951#discussion_r470036542 ## File path: rust/datafusion/src/execution/physical_plan/merge.rs ## @@ -64,33 +75,51 @@ struct MergePartition { schema: SchemaRef, /// Input p

[GitHub] [arrow] andygrove commented on a change in pull request #7951: ARROW-9716: [Rust] [DataFusion] Implement limit on concurrent threads in MergeExec

andygrove commented on a change in pull request #7951: URL: https://github.com/apache/arrow/pull/7951#discussion_r469629508 ## File path: rust/datafusion/src/execution/context.rs ## @@ -80,9 +82,16 @@ fn tuple_err(value: (Result, Result)) -> Result<(T, R)> { impl ExecutionCon