diff --git a/src/main/java/org/pentaho/di/dataset/DataSetCsvGroup.java b/src/main/java/org/pentaho/di/dataset/DataSetCsvGroup.java index 74249d3..9ec0f5d 100644 --- a/src/main/java/org/pentaho/di/dataset/DataSetCsvGroup.java +++ b/src/main/java/org/pentaho/di/dataset/DataSetCsvGroup.java @@ -191,8 +191,9 @@ public static final List getAllRows( LogChannelInterface log, DataSetG int index = dataSetFieldIndexes[ i ]; ValueMetaInterface valueMeta = setRowMeta.getValueMeta( index ); + constantValueMeta.setConversionMetadata( valueMeta ); String value = csvRecord.get( index ); - row[ i ] = valueMeta.convertDataFromString( value, constantValueMeta, null, null, ValueMetaInterface.TRIM_TYPE_NONE ); + row[ i ] = valueMeta.convertData( constantValueMeta, value ); } rows.add( row ); }