Skip to content

Commit cdb2321

Browse files
authored
Improve IcebergCommitExec to correctly specify properties schema (#22)
1 parent 15e2fc9 commit cdb2321

File tree

1 file changed

+5
-2
lines changed
  • crates/integrations/datafusion/src/physical_plan

1 file changed

+5
-2
lines changed

crates/integrations/datafusion/src/physical_plan/commit.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,14 +57,17 @@ impl IcebergCommitExec {
5757
input: Arc<dyn ExecutionPlan>,
5858
schema: ArrowSchemaRef,
5959
) -> Self {
60-
let plan_properties = Self::compute_properties(schema.clone());
60+
61+
let count_schema = Self::make_count_schema();
62+
63+
let plan_properties = Self::compute_properties(Arc::clone(&count_schema));
6164

6265
Self {
6366
table,
6467
catalog,
6568
input,
6669
schema,
67-
count_schema: Self::make_count_schema(),
70+
count_schema,
6871
plan_properties,
6972
}
7073
}

0 commit comments

Comments
 (0)