From 926d92bac13ff8171d503aa0f7b429e030284e2f Mon Sep 17 00:00:00 2001
From: Kate Ting <kathleen@apache.org>
Date: Fri, 15 Jan 2016 16:00:34 -0800
Subject: [PATCH] SQOOP-2783: Query import with parquet fails on incompatible
 schema  (Jarek Jarcec Cecho via Kate Ting)

---
 src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java b/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java
index dcffb995..0a693d02 100644
--- a/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java
+++ b/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java
@@ -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);