[importer] Fix import using impala without hive
@@ -164,7 +164,8 @@ class SQLIndexer(object):
'overwrite': False,
'partition_columns': [(partition['name'], partition['partitionValue']) for partition in partition_columns],
}
- db = dbms.get(self.user)
+ query_server_config = dbms.get_query_server_config(name=source_type)
+ db = dbms.get(self.user, query_server=query_server_config)
sql += "\n\n%s;" % db.load_data(database, table_name, form_data, None, generate_ddl_only=True)
if load_data and table_format in ('parquet', 'kudu'):
