diff --git a/superset/db_engine_specs.py b/superset/db_engine_specs.py index 0f10d82a9d41f..e2f4f70ec85df 100644 --- a/superset/db_engine_specs.py +++ b/superset/db_engine_specs.py @@ -1050,7 +1050,8 @@ def convert_to_hive_type(col_type): for column_info in hive_table_schema['fields']: column_name_and_type.append( '{} {}'.format( - column_info['name'], convert_to_hive_type(column_info['type']))) + "'" + column_info['name'] + "'", + convert_to_hive_type(column_info['type']))) schema_definition = ', '.join(column_name_and_type) s3 = boto3.client('s3')