diff --git a/be/src/vec/sink/mysql_result_writer.cpp b/be/src/vec/sink/mysql_result_writer.cpp index 489b70ed8c..55fa8aaf41 100644 --- a/be/src/vec/sink/mysql_result_writer.cpp +++ b/be/src/vec/sink/mysql_result_writer.cpp @@ -283,6 +283,12 @@ int VMysqlResultWriter::_add_one_cell(const ColumnPtr& column_ptr, size_t row_id char buf[64]; char* pos = datetime.to_string(buf); return buffer.push_string(buf, pos - buf - 1); + } else if (which.is_decimal128()) { + auto& column_data = + static_cast&>(*column).get_data(); + DecimalV2Value decimal_val(column_data[row_idx]); + auto decimal_str = decimal_val.to_string(); + return buffer.push_string(decimal_str.c_str(), decimal_str.length()); } else if (which.is_array()) { auto& column_array = assert_cast(*column); auto& offsets = column_array.get_offsets();