diff --git a/service/src/java/org/apache/hive/service/cli/TableSchema.java b/service/src/java/org/apache/hive/service/cli/TableSchema.java index d8812181f835..a80ecd5173b7 100644 --- a/service/src/java/org/apache/hive/service/cli/TableSchema.java +++ b/service/src/java/org/apache/hive/service/cli/TableSchema.java @@ -49,6 +49,9 @@ public TableSchema(TTableSchema tTableSchema) { public TableSchema(List fieldSchemas) { int pos = 1; + if (fieldSchemas == null) { + return; + } for (FieldSchema field : fieldSchemas) { columns.add(new ColumnDescriptor(field.getName(), field.getComment(), new TypeDescriptor( field.getType()), pos++)); @@ -78,6 +81,7 @@ public void clear() { public TTableSchema toTTableSchema() { TTableSchema tTableSchema = new TTableSchema(); + tTableSchema.setColumns(new ArrayList<>()); for (ColumnDescriptor col : columns) { tTableSchema.addToColumns(col.toTColumnDesc()); }