Skip to content

Commit d782205

Browse files
committed
fix standalone context creation
1 parent 01534b4 commit d782205

File tree

2 files changed

+3
-13
lines changed

2 files changed

+3
-13
lines changed

ballista/scheduler/src/standalone.rs

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ use ballista_core::{
2929
error::Result, serde::protobuf::scheduler_grpc_server::SchedulerGrpcServer,
3030
BALLISTA_VERSION,
3131
};
32-
use datafusion::execution::{SessionState, SessionStateBuilder};
32+
use datafusion::execution::SessionState;
3333
use datafusion::prelude::SessionConfig;
3434
use datafusion_proto::protobuf::LogicalPlanNode;
3535
use datafusion_proto::protobuf::PhysicalPlanNode;
@@ -56,14 +56,7 @@ pub async fn new_standalone_scheduler_from_state(
5656
let codec = BallistaCodec::new(logical, physical);
5757
let session_config = session_state.config().clone();
5858
let session_state = session_state.clone();
59-
let session_builder = Arc::new(move |c: SessionConfig| {
60-
Ok(
61-
SessionStateBuilder::new_from_existing(session_state.clone())
62-
.with_config(c)
63-
.build(),
64-
)
65-
});
66-
59+
let session_builder = Arc::new(move |_: SessionConfig| Ok(session_state.clone()));
6760
let config_producer = Arc::new(move || session_config.clone());
6861

6962
new_standalone_scheduler_with_builder(session_builder, config_producer, codec).await

examples/tests/common/mod.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -168,10 +168,7 @@ fn init() {
168168
// Enable RUST_LOG logging configuration for test
169169
let _ = env_logger::builder()
170170
.filter_level(log::LevelFilter::Info)
171-
.parse_filters(
172-
"ballista=debug,ballista_scheduler-rs=debug,ballista_executor=debug",
173-
)
174-
//.parse_filters("ballista=debug,ballista_scheduler-rs=debug,ballista_executor=debug,datafusion=debug")
171+
.parse_filters("ballista=debug,ballista_scheduler=debug,ballista_executor=debug")
175172
.is_test(true)
176173
.try_init();
177174
}

0 commit comments

Comments
 (0)