diff --git a/src/datatypes/src/vectors/json/array.rs b/src/datatypes/src/vectors/json/array.rs index 45ebafb8ed..3d496ee30f 100644 --- a/src/datatypes/src/vectors/json/array.rs +++ b/src/datatypes/src/vectors/json/array.rs @@ -84,7 +84,7 @@ impl JsonArray<'_> { return UnsupportedArrowTypeSnafu { arrow_type: other.clone(), } - .fail(); + .fail(); } }; common_telemetry::debug!("after serialize: {:?}", value); diff --git a/src/mito2/src/sst/parquet/flat_format.rs b/src/mito2/src/sst/parquet/flat_format.rs index 1df509e793..303e0e41f5 100644 --- a/src/mito2/src/sst/parquet/flat_format.rs +++ b/src/mito2/src/sst/parquet/flat_format.rs @@ -108,7 +108,7 @@ impl FlatWriteFormat { &self.arrow_schema, columns, ) - .context(RecordBatchSnafu)?; + .context(RecordBatchSnafu)?; RecordBatch::try_new(batch.schema(), columns).context(NewRecordBatchSnafu) } } diff --git a/tests/cases/standalone/common/types/json/jsonbench.result b/tests/cases/standalone/common/types/json/jsonbench.result index 5ad96a504b..3de4caa1b2 100644 --- a/tests/cases/standalone/common/types/json/jsonbench.result +++ b/tests/cases/standalone/common/types/json/jsonbench.result @@ -174,3 +174,7 @@ FROM bluesky; | | | +---------------+--------------------------------------------------------------------------------------------------------------------------------+ +DROP TABLE bluesky; + +Affected Rows: 0 + diff --git a/tests/cases/standalone/common/types/json/jsonbench.sql b/tests/cases/standalone/common/types/json/jsonbench.sql index c3f74ccec4..8d25605ded 100644 --- a/tests/cases/standalone/common/types/json/jsonbench.sql +++ b/tests/cases/standalone/common/types/json/jsonbench.sql @@ -88,3 +88,5 @@ LIMIT 3; EXPLAIN SELECT date_part('hour', to_timestamp_micros(arrow_cast(data.time_us, 'Int64'))) as hour_of_day FROM bluesky; + +DROP TABLE bluesky;