diff --git a/src/java/com/cloudera/sqoop/orm/ClassWriter.java b/src/java/com/cloudera/sqoop/orm/ClassWriter.java index 59a1973d..9e3a454e 100644 --- a/src/java/com/cloudera/sqoop/orm/ClassWriter.java +++ b/src/java/com/cloudera/sqoop/orm/ClassWriter.java @@ -473,7 +473,8 @@ private void generateDbRead(Map columnTypes, int sqlType = columnTypes.get(col); String javaType = connManager.toJavaType(sqlType); 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; } @@ -512,7 +513,8 @@ private void generateLoadLargeObjects(Map columnTypes, int sqlType = columnTypes.get(col); String javaType = connManager.toJavaType(sqlType); 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; } @@ -555,7 +557,8 @@ private void generateDbWrite(Map columnTypes, int sqlType = columnTypes.get(col); String javaType = connManager.toJavaType(sqlType); 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; } @@ -590,7 +593,8 @@ private void generateHadoopRead(Map columnTypes, int sqlType = columnTypes.get(col); String javaType = connManager.toJavaType(sqlType); 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; } @@ -693,7 +697,8 @@ private void generateToString(Map columnTypes, int sqlType = columnTypes.get(col); String javaType = connManager.toJavaType(sqlType); 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; } @@ -862,7 +867,8 @@ private void generateHadoopWrite(Map columnTypes, int sqlType = columnTypes.get(col); String javaType = connManager.toJavaType(sqlType); 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; }