diff --git a/pyhive/hive.py b/pyhive/hive.py index 3f71df33..c35943cf 100644 --- a/pyhive/hive.py +++ b/pyhive/hive.py @@ -449,7 +449,7 @@ def execute(self, operation, parameters=None, **kwargs): _logger.info('%s', sql) req = ttypes.TExecuteStatementReq(self._connection.sessionHandle, - sql, runAsync=async_) + sql, kwargs.get("confOverlay", None), runAsync=async_) _logger.debug(req) response = self._connection.client.ExecuteStatement(req) _check_status(response)