Schema mismatch causes transformation failures

Source data type does not match pipeline's expected schema, causing transformation to fail when encountering incompatible field types

Update pipeline schema to match actual source data types, or add transform stage to cast fields to expected types before downstream processing