github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-04 06:22:46 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-165. Improved log message for unknown types.

Browse Source 
(Lars Francke via Arvind Prabhakar)

From: Arvind Prabhakar <arvind@cloudera.com>

git-svn-id: https://svn.apache.org/repos/asf/incubator/sqoop/trunk@1150015 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Andrew Bayer 2011-07-22 20:04:29 +00:00
parent 6f2e5c683a
commit 5774ddd6db
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/java/com/cloudera/sqoop/orm/ClassWriter.java
View File

@ -473,7 +473,8 @@ private void generateDbRead(Map<String, Integer> columnTypes,
int sqlType = columnTypes.get(col); int sqlType = columnTypes.get(col);
String javaType = connManager.toJavaType(sqlType); String javaType = connManager.toJavaType(sqlType);
if (null == javaType) { if (null == javaType) {
LOG.error("No Java type for SQL type " + sqlType); LOG.error("No Java type for SQL type " + sqlType
+ " for column " + col);
continue; continue;
} }
@ -512,7 +513,8 @@ private void generateLoadLargeObjects(Map<String, Integer> columnTypes,
int sqlType = columnTypes.get(col); int sqlType = columnTypes.get(col);
String javaType = connManager.toJavaType(sqlType); String javaType = connManager.toJavaType(sqlType);
if (null == javaType) { if (null == javaType) {
LOG.error("No Java type for SQL type " + sqlType); LOG.error("No Java type for SQL type " + sqlType
+ " for column " + col);
continue; continue;
} }
@ -555,7 +557,8 @@ private void generateDbWrite(Map<String, Integer> columnTypes,
int sqlType = columnTypes.get(col); int sqlType = columnTypes.get(col);
String javaType = connManager.toJavaType(sqlType); String javaType = connManager.toJavaType(sqlType);
if (null == javaType) { if (null == javaType) {
LOG.error("No Java type for SQL type " + sqlType); LOG.error("No Java type for SQL type " + sqlType
+ " for column " + col);
continue; continue;
} }
@ -590,7 +593,8 @@ private void generateHadoopRead(Map<String, Integer> columnTypes,
int sqlType = columnTypes.get(col); int sqlType = columnTypes.get(col);
String javaType = connManager.toJavaType(sqlType); String javaType = connManager.toJavaType(sqlType);
if (null == javaType) { if (null == javaType) {
LOG.error("No Java type for SQL type " + sqlType); LOG.error("No Java type for SQL type " + sqlType
+ " for column " + col);
continue; continue;
} }
@ -693,7 +697,8 @@ private void generateToString(Map<String, Integer> columnTypes,
int sqlType = columnTypes.get(col); int sqlType = columnTypes.get(col);
String javaType = connManager.toJavaType(sqlType); String javaType = connManager.toJavaType(sqlType);
if (null == javaType) { if (null == javaType) {
LOG.error("No Java type for SQL type " + sqlType); LOG.error("No Java type for SQL type " + sqlType
+ " for column " + col);
continue; continue;
} }
@ -862,7 +867,8 @@ private void generateHadoopWrite(Map<String, Integer> columnTypes,
int sqlType = columnTypes.get(col); int sqlType = columnTypes.get(col);
String javaType = connManager.toJavaType(sqlType); String javaType = connManager.toJavaType(sqlType);
if (null == javaType) { if (null == javaType) {
LOG.error("No Java type for SQL type " + sqlType); LOG.error("No Java type for SQL type " + sqlType
+ " for column " + col);
continue; continue;
} }