Skip to content

WIP Built some initial e2e datafusion infrastructure #33

WIP Built some initial e2e datafusion infrastructure

WIP Built some initial e2e datafusion infrastructure #33

Triggered via pull request January 20, 2025 20:50
Status Failure
Total duration 6m 43s
Artifacts

test.yml

on: pull_request
ubuntu / stable / minimal-versions
50s
ubuntu / stable / minimal-versions
Matrix: os-check
Matrix: required
Fit to window
Zoom out
Zoom in

Annotations

1 error and 69 warnings
ubuntu / stable / minimal-versions
Process completed with exit code 101.
ubuntu / stable / minimal-versions
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
[clippy] infra/src/query_planner.rs#L15: infra/src/query_planner.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:15:41 | 15 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] infra/src/query_planner.rs#L164: infra/src/query_planner.rs#L164
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:164:23 | 164 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L181: infra/src/query_planner.rs#L181
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:181:9 | 181 | RuntimeConfig::new() | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L79: infra/src/query_planner.rs#L79
warning: unused variable: `verbose` --> infra/src/query_planner.rs:79:28 | 79 | let (mut explains, verbose, logical_plan) = match logical_plan { | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_verbose` | = note: `#[warn(unused_variables)]` on by default
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: unused variable: `ctx` --> infra/src/query_planner.rs:85:17 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ^^^ help: if this is intentional, prefix it with an underscore: `_ctx`
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: unused variable: `optimizer` --> infra/src/query_planner.rs:94:17 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: variable does not need to be mutable --> infra/src/query_planner.rs:85:13 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ----^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: variable does not need to be mutable --> infra/src/query_planner.rs:94:13 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ----^^^^^^^^^ | | | help: remove this `mut`
[clippy] infra/src/query_planner.rs#L27: infra/src/query_planner.rs#L27
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdPlanContext::optimizer` --> infra/src/query_planner.rs:27:5 | 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdPlanContext::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default
[clippy] infra/src/query_planner.rs#L41: infra/src/query_planner.rs#L41
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::optimizer` --> infra/src/query_planner.rs:41:5 | 41 | pub optimizer: Arc<Mutex<Option<Box<DatafusionOptimizer>>>>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdQueryPlanner::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L107: infra/src/query_planner.rs#L107
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::new` --> infra/src/query_planner.rs:107:5 | 107 | pub fn new(optimizer: DatafusionOptimizer) -> Self { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `query_planner::OptdQueryPlanner::new` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L24: infra/src/query_planner.rs#L24
warning: fields `tables`, `session_state`, and `optimizer` are never read --> infra/src/query_planner.rs:25:5 | 24 | pub struct OptdPlanContext<'a> { | --------------- fields in this struct 25 | tables: HashMap<String, Arc<dyn TableSource>>, | ^^^^^^ 26 | session_state: &'a SessionState, | ^^^^^^^^^^^^^ 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^ | = note: `#[warn(dead_code)]` on by default
[clippy] infra/src/query_planner.rs#L44: infra/src/query_planner.rs#L44
warning: associated items `enable_adaptive`, `disable_adaptive`, and `new` are never used --> infra/src/query_planner.rs:45:12 | 44 | impl OptdQueryPlanner { | --------------------- associated items in this implementation 45 | pub fn enable_adaptive(&self) { | ^^^^^^^^^^^^^^^ ... 55 | pub fn disable_adaptive(&self) { | ^^^^^^^^^^^^^^^^ ... 107 | pub fn new(optimizer: DatafusionOptimizer) -> Self { | ^^^
[clippy] infra/src/query_planner.rs#L135: infra/src/query_planner.rs#L135
warning: enum `JoinOrder` is never used --> infra/src/query_planner.rs:135:6 | 135 | enum JoinOrder { | ^^^^^^^^^
[clippy] infra/src/query_planner.rs#L155: infra/src/query_planner.rs#L155
warning: struct `OptdDfContext` is never constructed --> infra/src/query_planner.rs:155:12 | 155 | pub struct OptdDfContext { | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L162: infra/src/query_planner.rs#L162
warning: function `create_df_context` is never used --> infra/src/query_planner.rs:162:14 | 162 | pub async fn create_df_context( | ^^^^^^^^^^^^^^^^^
[clippy] infra/src/main.rs#L4: infra/src/main.rs#L4
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/main.rs:4:41 | 4 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] infra/src/main.rs#L15: infra/src/main.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/main.rs:15:21 | 15 | let rt_config = RuntimeConfig::new(); | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L15: infra/src/query_planner.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:15:41 | 15 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L164: infra/src/query_planner.rs#L164
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:164:23 | 164 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L181: infra/src/query_planner.rs#L181
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:181:9 | 181 | RuntimeConfig::new() | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L79: infra/src/query_planner.rs#L79
warning: unused variable: `verbose` --> infra/src/query_planner.rs:79:28 | 79 | let (mut explains, verbose, logical_plan) = match logical_plan { | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_verbose` | = note: `#[warn(unused_variables)]` on by default
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: unused variable: `ctx` --> infra/src/query_planner.rs:85:17 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ^^^ help: if this is intentional, prefix it with an underscore: `_ctx`
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: unused variable: `optimizer` --> infra/src/query_planner.rs:94:17 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: variable does not need to be mutable --> infra/src/query_planner.rs:85:13 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ----^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: variable does not need to be mutable --> infra/src/query_planner.rs:94:13 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ----^^^^^^^^^ | | | help: remove this `mut`
[clippy] infra/src/query_planner.rs#L27: infra/src/query_planner.rs#L27
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdPlanContext::optimizer` --> infra/src/query_planner.rs:27:5 | 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdPlanContext::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default
[clippy] infra/src/query_planner.rs#L41: infra/src/query_planner.rs#L41
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::optimizer` --> infra/src/query_planner.rs:41:5 | 41 | pub optimizer: Arc<Mutex<Option<Box<DatafusionOptimizer>>>>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdQueryPlanner::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L107: infra/src/query_planner.rs#L107
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::new` --> infra/src/query_planner.rs:107:5 | 107 | pub fn new(optimizer: DatafusionOptimizer) -> Self { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `query_planner::OptdQueryPlanner::new` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L24: infra/src/query_planner.rs#L24
warning: fields `tables`, `session_state`, and `optimizer` are never read --> infra/src/query_planner.rs:25:5 | 24 | pub struct OptdPlanContext<'a> { | --------------- fields in this struct 25 | tables: HashMap<String, Arc<dyn TableSource>>, | ^^^^^^ 26 | session_state: &'a SessionState, | ^^^^^^^^^^^^^ 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^ | = note: `#[warn(dead_code)]` on by default
[clippy] infra/src/query_planner.rs#L44: infra/src/query_planner.rs#L44
warning: methods `enable_adaptive` and `disable_adaptive` are never used --> infra/src/query_planner.rs:45:12 | 44 | impl OptdQueryPlanner { | --------------------- methods in this implementation 45 | pub fn enable_adaptive(&self) { | ^^^^^^^^^^^^^^^ ... 55 | pub fn disable_adaptive(&self) { | ^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L135: infra/src/query_planner.rs#L135
warning: enum `JoinOrder` is never used --> infra/src/query_planner.rs:135:6 | 135 | enum JoinOrder { | ^^^^^^^^^
[clippy] infra/src/query_planner.rs#L155: infra/src/query_planner.rs#L155
warning: fields `catalog` and `optimizer` are never read --> infra/src/query_planner.rs:157:9 | 155 | pub struct OptdDfContext { | ------------- fields in this struct 156 | pub ctx: SessionContext, 157 | pub catalog: Arc<dyn CatalogProviderList>, | ^^^^^^^ 158 | pub optimizer: Arc<OptdQueryPlanner>, | ^^^^^^^^^
[clippy] infra/src/query_planner.rs#L15: infra/src/query_planner.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:15:41 | 15 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] infra/src/query_planner.rs#L164: infra/src/query_planner.rs#L164
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:164:23 | 164 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L181: infra/src/query_planner.rs#L181
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:181:9 | 181 | RuntimeConfig::new() | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L79: infra/src/query_planner.rs#L79
warning: unused variable: `verbose` --> infra/src/query_planner.rs:79:28 | 79 | let (mut explains, verbose, logical_plan) = match logical_plan { | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_verbose` | = note: `#[warn(unused_variables)]` on by default
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: unused variable: `ctx` --> infra/src/query_planner.rs:85:17 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ^^^ help: if this is intentional, prefix it with an underscore: `_ctx`
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: unused variable: `optimizer` --> infra/src/query_planner.rs:94:17 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: variable does not need to be mutable --> infra/src/query_planner.rs:85:13 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ----^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: variable does not need to be mutable --> infra/src/query_planner.rs:94:13 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ----^^^^^^^^^ | | | help: remove this `mut`
[clippy] infra/src/query_planner.rs#L27: infra/src/query_planner.rs#L27
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdPlanContext::optimizer` --> infra/src/query_planner.rs:27:5 | 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdPlanContext::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default
[clippy] infra/src/query_planner.rs#L41: infra/src/query_planner.rs#L41
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::optimizer` --> infra/src/query_planner.rs:41:5 | 41 | pub optimizer: Arc<Mutex<Option<Box<DatafusionOptimizer>>>>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdQueryPlanner::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L107: infra/src/query_planner.rs#L107
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::new` --> infra/src/query_planner.rs:107:5 | 107 | pub fn new(optimizer: DatafusionOptimizer) -> Self { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `query_planner::OptdQueryPlanner::new` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L24: infra/src/query_planner.rs#L24
warning: fields `tables`, `session_state`, and `optimizer` are never read --> infra/src/query_planner.rs:25:5 | 24 | pub struct OptdPlanContext<'a> { | --------------- fields in this struct 25 | tables: HashMap<String, Arc<dyn TableSource>>, | ^^^^^^ 26 | session_state: &'a SessionState, | ^^^^^^^^^^^^^ 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^ | = note: `#[warn(dead_code)]` on by default
[clippy] infra/src/query_planner.rs#L44: infra/src/query_planner.rs#L44
warning: associated items `enable_adaptive`, `disable_adaptive`, and `new` are never used --> infra/src/query_planner.rs:45:12 | 44 | impl OptdQueryPlanner { | --------------------- associated items in this implementation 45 | pub fn enable_adaptive(&self) { | ^^^^^^^^^^^^^^^ ... 55 | pub fn disable_adaptive(&self) { | ^^^^^^^^^^^^^^^^ ... 107 | pub fn new(optimizer: DatafusionOptimizer) -> Self { | ^^^
[clippy] infra/src/query_planner.rs#L135: infra/src/query_planner.rs#L135
warning: enum `JoinOrder` is never used --> infra/src/query_planner.rs:135:6 | 135 | enum JoinOrder { | ^^^^^^^^^
[clippy] infra/src/query_planner.rs#L155: infra/src/query_planner.rs#L155
warning: struct `OptdDfContext` is never constructed --> infra/src/query_planner.rs:155:12 | 155 | pub struct OptdDfContext { | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L162: infra/src/query_planner.rs#L162
warning: function `create_df_context` is never used --> infra/src/query_planner.rs:162:14 | 162 | pub async fn create_df_context( | ^^^^^^^^^^^^^^^^^
[clippy] infra/src/main.rs#L4: infra/src/main.rs#L4
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/main.rs:4:41 | 4 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] infra/src/main.rs#L15: infra/src/main.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/main.rs:15:21 | 15 | let rt_config = RuntimeConfig::new(); | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L15: infra/src/query_planner.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:15:41 | 15 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L164: infra/src/query_planner.rs#L164
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:164:23 | 164 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L181: infra/src/query_planner.rs#L181
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/query_planner.rs:181:9 | 181 | RuntimeConfig::new() | ^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L79: infra/src/query_planner.rs#L79
warning: unused variable: `verbose` --> infra/src/query_planner.rs:79:28 | 79 | let (mut explains, verbose, logical_plan) = match logical_plan { | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_verbose` | = note: `#[warn(unused_variables)]` on by default
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: unused variable: `ctx` --> infra/src/query_planner.rs:85:17 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ^^^ help: if this is intentional, prefix it with an underscore: `_ctx`
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: unused variable: `optimizer` --> infra/src/query_planner.rs:94:17 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`
[clippy] infra/src/query_planner.rs#L85: infra/src/query_planner.rs#L85
warning: variable does not need to be mutable --> infra/src/query_planner.rs:85:13 | 85 | let mut ctx = OptdPlanContext::new(session_state); | ----^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default
[clippy] infra/src/query_planner.rs#L94: infra/src/query_planner.rs#L94
warning: variable does not need to be mutable --> infra/src/query_planner.rs:94:13 | 94 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap(); | ----^^^^^^^^^ | | | help: remove this `mut`
[clippy] infra/src/query_planner.rs#L27: infra/src/query_planner.rs#L27
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdPlanContext::optimizer` --> infra/src/query_planner.rs:27:5 | 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdPlanContext::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default
[clippy] infra/src/query_planner.rs#L41: infra/src/query_planner.rs#L41
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::optimizer` --> infra/src/query_planner.rs:41:5 | 41 | pub optimizer: Arc<Mutex<Option<Box<DatafusionOptimizer>>>>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `query_planner::OptdQueryPlanner::optimizer` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L107: infra/src/query_planner.rs#L107
warning: type `query_planner::DatafusionOptimizer` is more private than the item `query_planner::OptdQueryPlanner::new` --> infra/src/query_planner.rs:107:5 | 107 | pub fn new(optimizer: DatafusionOptimizer) -> Self { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `query_planner::OptdQueryPlanner::new` is reachable at visibility `pub(crate)` | note: but type `query_planner::DatafusionOptimizer` is only usable at visibility `pub(self)` --> infra/src/query_planner.rs:22:1 | 22 | struct DatafusionOptimizer {} | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L24: infra/src/query_planner.rs#L24
warning: fields `tables`, `session_state`, and `optimizer` are never read --> infra/src/query_planner.rs:25:5 | 24 | pub struct OptdPlanContext<'a> { | --------------- fields in this struct 25 | tables: HashMap<String, Arc<dyn TableSource>>, | ^^^^^^ 26 | session_state: &'a SessionState, | ^^^^^^^^^^^^^ 27 | pub optimizer: Option<&'a DatafusionOptimizer>, | ^^^^^^^^^ | = note: `#[warn(dead_code)]` on by default
[clippy] infra/src/query_planner.rs#L44: infra/src/query_planner.rs#L44
warning: methods `enable_adaptive` and `disable_adaptive` are never used --> infra/src/query_planner.rs:45:12 | 44 | impl OptdQueryPlanner { | --------------------- methods in this implementation 45 | pub fn enable_adaptive(&self) { | ^^^^^^^^^^^^^^^ ... 55 | pub fn disable_adaptive(&self) { | ^^^^^^^^^^^^^^^^
[clippy] infra/src/query_planner.rs#L135: infra/src/query_planner.rs#L135
warning: enum `JoinOrder` is never used --> infra/src/query_planner.rs:135:6 | 135 | enum JoinOrder { | ^^^^^^^^^
[clippy] infra/src/query_planner.rs#L155: infra/src/query_planner.rs#L155
warning: fields `catalog` and `optimizer` are never read --> infra/src/query_planner.rs:157:9 | 155 | pub struct OptdDfContext { | ------------- fields in this struct 156 | pub ctx: SessionContext, 157 | pub catalog: Arc<dyn CatalogProviderList>, | ^^^^^^^ 158 | pub optimizer: Arc<OptdQueryPlanner>, | ^^^^^^^^^
ubuntu / beta
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
ubuntu / stable
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636