Try to fix executor from within another executor error
@@ -42,8 +42,8 @@ impl PlanDoReadSource {
impl PlanRewriter for PlanDoReadSource {
fn rewrite_read_data_source(&mut self, plan: &ReadDataSourcePlan) -> Result<PlanNode> {
let context = self.ctx.clone();
- futures::executor::block_on(async move {
let table = context.build_table_from_source_plan(plan)?;
+ futures::executor::block_on(async move {
let plan = table
.read_plan(context.clone(), plan.push_downs.clone())
.await?;
