github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-17 01:11:07 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-2783: Query import with parquet fails on incompatible schema

Browse Source 
(Jarek Jarcec Cecho via Kate Ting)
This commit is contained in:
Kate Ting 2016-01-15 16:00:34 -08:00
parent 1e310ad9f5
commit 926d92bac1
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java
View File

@ -48,6 +48,8 @@ public class AvroSchemaGenerator {
private final ConnManager connManager;
private final String tableName;
private final String DEFAULT_SCHEMA_NAME = "AutoGeneratedSchema";
public AvroSchemaGenerator(final SqoopOptions opts, final ConnManager connMgr,
final String table) {
this.options = opts;
@ -78,7 +80,7 @@ public Schema generate(String schemaNameOverride) throws IOException {
}
TableClassName tableClassName = new TableClassName(options);
String shortClassName = tableClassName.getShortClassForTable(tableName);
String shortClassName = tableName == null ? DEFAULT_SCHEMA_NAME : tableClassName.getShortClassForTable(tableName);
String avroTableName = (tableName == null ? TableClassName.QUERY_RESULT : tableName);
String avroName = schemaNameOverride != null ? schemaNameOverride :
(shortClassName == null ? avroTableName : shortClassName);