Updated Branches: refs/heads/trunk 465c2751f -> d4767e9f6
SQOOP-615: Error in Avro generation (Giovanni Ruggiero via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/d4767e9f Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/d4767e9f Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/d4767e9f Branch: refs/heads/trunk Commit: d4767e9f61ffba74a6948eae7b9d03d5c03d6899 Parents: 465c275 Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu Sep 27 12:58:35 2012 +0200 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu Sep 27 12:58:35 2012 +0200 ---------------------------------------------------------------------- .../org/apache/sqoop/orm/AvroSchemaGenerator.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/d4767e9f/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java b/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java index 30fea5e..864fa0d 100644 --- a/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java +++ b/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java @@ -61,7 +61,7 @@ public class AvroSchemaGenerator { List<Field> fields = new ArrayList<Field>(); for (String columnName : columnNames) { String cleanedCol = ClassWriter.toIdentifier(columnName); - int sqlType = columnTypes.get(cleanedCol); + int sqlType = columnTypes.get(columnName); Schema avroSchema = toAvroSchema(sqlType, columnName); Field field = new Field(cleanedCol, avroSchema, null, null); field.addProp("columnName", columnName);
