You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2012/09/27 13:00:42 UTC
git commit: SQOOP-615: Error in Avro generation
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 <ja...@cloudera.com>
Authored: Thu Sep 27 12:58:35 2012 +0200
Committer: Jarek Jarcec Cecho <ja...@cloudera.com>
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);