We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 21d8281 commit d225cc7Copy full SHA for d225cc7
1 file changed
quickwit/quickwit-parquet-engine/src/storage/writer.rs
@@ -303,7 +303,8 @@ impl ParquetWriter {
303
batch: &RecordBatch,
304
split_metadata: Option<&MetricsSplitMetadata>,
305
) -> Result<(RecordBatch, WriterProperties), ParquetWriteError> {
306
- validate_required_fields(&batch.schema()).map_err(ParquetWriteError::SchemaValidation)?;
+ validate_required_fields(&batch.schema())
307
+ .map_err(|e| ParquetWriteError::SchemaValidation(e.to_string()))?;
308
let sorted_batch = self.sort_batch(batch)?;
309
310
let kv_metadata = split_metadata.map(build_compaction_key_value_metadata);
0 commit comments