diff --git a/src/cmd/joinp.rs b/src/cmd/joinp.rs index d89db91cc..b9153915e 100644 --- a/src/cmd/joinp.rs +++ b/src/cmd/joinp.rs @@ -458,6 +458,7 @@ impl JoinStruct { .with_time_format(self.time_format) .with_float_precision(self.float_precision) .with_null_value(self.null_value) + .include_bom(util::get_envvar_flag("QSV_OUTPUT_BOM")) .finish(&mut results_df)?; compress_output_if_needed(self.output)?; diff --git a/src/cmd/sqlp.rs b/src/cmd/sqlp.rs index d5fe14f15..a0446aa2d 100644 --- a/src/cmd/sqlp.rs +++ b/src/cmd/sqlp.rs @@ -280,6 +280,7 @@ impl OutputMode { .with_time_format(args.flag_time_format) .with_float_precision(args.flag_float_precision) .with_null_value(args.flag_wnull_value) + .include_bom(util::get_envvar_flag("QSV_OUTPUT_BOM")) .finish(&mut df), OutputMode::Json => JsonWriter::new(&mut w).finish(&mut df), OutputMode::Parquet => {