File tree Expand file tree Collapse file tree 1 file changed +1
-8
lines changed
datafusion/datasource-parquet/src Expand file tree Collapse file tree 1 file changed +1
-8
lines changed Original file line number Diff line number Diff line change @@ -1124,14 +1124,7 @@ impl ParquetSink {
1124
1124
runtime : & Arc < RuntimeEnv > ,
1125
1125
path : & Path ,
1126
1126
) -> Result < WriterProperties > {
1127
- let schema = if self . parquet_options . global . allow_single_file_parallelism {
1128
- // If parallelizing writes, we may be also be doing hive style partitioning
1129
- // into multiple files which impacts the schema per file.
1130
- // Refer to `get_writer_schema()`
1131
- & get_writer_schema ( & self . config )
1132
- } else {
1133
- self . config . output_schema ( )
1134
- } ;
1127
+ let schema = self . config . output_schema ( ) ;
1135
1128
1136
1129
// TODO: avoid this clone in follow up PR, where the writer properties & schema
1137
1130
// are calculated once on `ParquetSink::new`
You can’t perform that action at this time.
0 commit comments