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 @@ -1128,14 +1128,7 @@ impl ParquetSink {
1128
1128
runtime : & Arc < RuntimeEnv > ,
1129
1129
path : & Path ,
1130
1130
) -> Result < WriterProperties > {
1131
- let schema = if self . parquet_options . global . allow_single_file_parallelism {
1132
- // If parallelizing writes, we may be also be doing hive style partitioning
1133
- // into multiple files which impacts the schema per file.
1134
- // Refer to `get_writer_schema()`
1135
- & get_writer_schema ( & self . config )
1136
- } else {
1137
- self . config . output_schema ( )
1138
- } ;
1131
+ let schema = self . config . output_schema ( ) ;
1139
1132
1140
1133
// TODO: avoid this clone in follow up PR, where the writer properties & schema
1141
1134
// are calculated once on `ParquetSink::new`
You can’t perform that action at this time.
0 commit comments