Skip to content

Commit c56e9a5

Browse files
committed
fix slt
1 parent a179700 commit c56e9a5

File tree

2 files changed

+10
-4
lines changed

2 files changed

+10
-4
lines changed

datafusion/execution/src/config.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -441,7 +441,10 @@ impl SessionConfig {
441441
self
442442
}
443443

444-
pub fn with_parquet_force_view_metadata(mut self, schema_force_view_types: bool) -> Self {
444+
pub fn with_parquet_force_view_metadata(
445+
mut self,
446+
schema_force_view_types: bool,
447+
) -> Self {
445448
self.options.execution.parquet.schema_force_view_types = schema_force_view_types;
446449
self
447450
}

datafusion/sqllogictest/test_files/insert_to_external.slt

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -456,13 +456,16 @@ explain insert into table_without_values select c1 from aggregate_test_100 order
456456
----
457457
logical_plan
458458
01)Dml: op=[Insert Into] table=[table_without_values]
459-
02)--Projection: aggregate_test_100.c1 AS c1
459+
02)--Projection: CAST(aggregate_test_100.c1 AS Utf8View) AS c1
460460
03)----Sort: aggregate_test_100.c1 ASC NULLS LAST
461461
04)------TableScan: aggregate_test_100 projection=[c1]
462462
physical_plan
463463
01)DataSinkExec: sink=ParquetSink(file_groups=[])
464-
02)--SortExec: expr=[c1@0 ASC NULLS LAST], preserve_partitioning=[false]
465-
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/testing/data/csv/aggregate_test_100.csv]]}, projection=[c1], file_type=csv, has_header=true
464+
02)--CoalescePartitionsExec
465+
03)----ProjectionExec: expr=[CAST(c1@0 AS Utf8View) as c1]
466+
04)------RepartitionExec: partitioning=RoundRobinBatch(8), input_partitions=1
467+
05)--------SortExec: expr=[c1@0 ASC NULLS LAST], preserve_partitioning=[false]
468+
06)----------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/testing/data/csv/aggregate_test_100.csv]]}, projection=[c1], file_type=csv, has_header=true
466469

467470
query I
468471
insert into table_without_values select c1 from aggregate_test_100 order by c1;

0 commit comments

Comments
 (0)