From 2321db29ccaef692365e607d1742c605707f079a Mon Sep 17 00:00:00 2001 From: laian Date: Mon, 26 Jun 2017 14:43:22 -0400 Subject: [PATCH 1/3] testa --- ibis/impala/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ibis/impala/client.py b/ibis/impala/client.py index 7f102acfa113..980fc75bc5fa 100644 --- a/ibis/impala/client.py +++ b/ibis/impala/client.py @@ -266,7 +266,7 @@ def _sleep_interval(start_time): while True: state = cur.status() if self._cursor._op_state_is_error(state): - raise OperationalError("Operation is in ERROR_STATE") + raise OperationalError(self._cursor.cursor_log()) if not cur._op_state_is_executing(state): break time.sleep(_sleep_interval(loop_start)) From a1c02c0743c4b0d0fcc54e50c0ef0031e02aa08e Mon Sep 17 00:00:00 2001 From: laian Date: Mon, 26 Jun 2017 14:45:40 -0400 Subject: [PATCH 2/3] set_trace --- ibis/impala/client.py | 1 + 1 file changed, 1 insertion(+) diff --git a/ibis/impala/client.py b/ibis/impala/client.py index 980fc75bc5fa..f53445ec7062 100644 --- a/ibis/impala/client.py +++ b/ibis/impala/client.py @@ -266,6 +266,7 @@ def _sleep_interval(start_time): while True: state = cur.status() if self._cursor._op_state_is_error(state): + import ipdb; ipdb.set_trace(); raise OperationalError(self._cursor.cursor_log()) if not cur._op_state_is_executing(state): break From feb32ee26829c273da0060ae50c84f0c1a8ab160 Mon Sep 17 00:00:00 2001 From: laian Date: Mon, 26 Jun 2017 14:47:11 -0400 Subject: [PATCH 3/3] set_trace --- ibis/impala/client.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/ibis/impala/client.py b/ibis/impala/client.py index f53445ec7062..fcd46eb6e9a8 100644 --- a/ibis/impala/client.py +++ b/ibis/impala/client.py @@ -266,8 +266,7 @@ def _sleep_interval(start_time): while True: state = cur.status() if self._cursor._op_state_is_error(state): - import ipdb; ipdb.set_trace(); - raise OperationalError(self._cursor.cursor_log()) + raise OperationalError(self._cursor.get_log()) if not cur._op_state_is_executing(state): break time.sleep(_sleep_interval(loop_start))