Skip to content

Commit d9937ce

Browse files
committed
feat(query): enable runtime cast transform in loading parquet files
1 parent a2702fb commit d9937ce

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/query/service/src/interpreters/interpreter_insert.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -379,8 +379,7 @@ impl Interpreter for InsertInterpreter {
379379
.format
380380
.exec_stream(input_context.clone(), &mut build_res.main_pipeline)?;
381381

382-
let format = StageFileFormatType::from_str(format)?;
383-
if StageFileFormatType::Parquet == format {
382+
if Ok(StageFileFormatType::Parquet) == StageFileFormatType::from_str(format) {
384383
let dest_schema = plan.schema();
385384
let func_ctx = self.ctx.get_function_context()?;
386385

0 commit comments

Comments
 (0)