|
|
@@ -108,7 +108,7 @@ class HiveServerTable(Table):
|
|
|
except ValueError: # DESCRIBE on columns and nested columns does not contain add'l rows beyond cols
|
|
|
return rows[col_row_index:]
|
|
|
except:
|
|
|
- LOG.exception('failed to extract columns')
|
|
|
+ # Impala does not have it
|
|
|
return rows
|
|
|
|
|
|
def _get_partition_column(self):
|
|
|
@@ -118,7 +118,7 @@ class HiveServerTable(Table):
|
|
|
end_cols_index = map(itemgetter('col_name'), rows[col_row_index:]).index('')
|
|
|
return rows[col_row_index:][:end_cols_index]
|
|
|
except:
|
|
|
- LOG.exception('failed to get partition column')
|
|
|
+ # Impala does not have it
|
|
|
return []
|
|
|
|
|
|
@property
|
|
|
@@ -291,8 +291,6 @@ class HiveServerTTableSchema:
|
|
|
try:
|
|
|
return HiveServerTRowSet(self.columns, self.schema).cols(('col_name', 'data_type', 'comment'))
|
|
|
except:
|
|
|
- LOG.exception('failed to get columns')
|
|
|
-
|
|
|
# Impala API is different
|
|
|
cols = HiveServerTRowSet(self.columns, self.schema).cols(('name', 'type', 'comment'))
|
|
|
for col in cols:
|