Signed-off-by: luofucong <luofc@foxmail.com>
This commit is contained in:
luofucong
2026-04-23 15:52:40 +08:00
parent a2d9d2de96
commit 7ed0dbf6f2
4 changed files with 8 additions and 2 deletions

View File

@@ -84,7 +84,7 @@ impl JsonArray<'_> {
return UnsupportedArrowTypeSnafu {
arrow_type: other.clone(),
}
.fail();
.fail();
}
};
common_telemetry::debug!("after serialize: {:?}", value);

View File

@@ -108,7 +108,7 @@ impl FlatWriteFormat {
&self.arrow_schema,
columns,
)
.context(RecordBatchSnafu)?;
.context(RecordBatchSnafu)?;
RecordBatch::try_new(batch.schema(), columns).context(NewRecordBatchSnafu)
}
}

View File

@@ -174,3 +174,7 @@ FROM bluesky;
| | |
+---------------+--------------------------------------------------------------------------------------------------------------------------------+
DROP TABLE bluesky;
Affected Rows: 0

View File

@@ -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;