jprdonnelly/impala
1
0
Fork 0
mirror of https://github.com/apache/impala.git synced 2025-12-23 21:08:39 -05:00
Code Issues Projects Releases Wiki Activity

IMPALA-2309: Compute stats query return error if set LIVE_PROGRESS=true

Browse Source 
Impala shell cannot get child query handle so it cannot
query live progress for COMPUTE STATS query. Disable live
progress callback for compute stats query.

Change-Id: I2d2f342a805905a4fa868686e7c9e9362c2c2223
Reviewed-on: http://gerrit.cloudera.org:8080/1109
Reviewed-by: Juan Yu <jyu@cloudera.com>
Tested-by: Internal Jenkins
This commit is contained in:
Juan Yu
2015-09-29 21:19:05 -07:00
committed by ishaan
parent 265bed6494
commit 0df3b419a0
2 changed files with 31 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
shell/impala_shell.py
View File

@@ -665,6 +665,21 @@ class ImpalaShell(cmd.Cmd):
self.set_query_options)
return self._execute_stmt(query)
def do_compute(self, args):
"""Executes a COMPUTE STATS query.
Impala shell cannot get child query handle so it cannot
query live progress for COMPUTE STATS query. Disable live
progress/summary callback for COMPUTE STATS query."""
query = self.imp_client.create_beeswax_query("compute %s" % args,
self.set_query_options)
(prev_print_progress, prev_print_summary) = self.print_progress, self.print_summary
(self.print_progress, self.print_summary) = False, False;
try:
ret = self._execute_stmt(query)
finally:
(self.print_progress, self.print_summary) = prev_print_progress, prev_print_summary
return ret
def _format_outputstream(self):
column_names = self.imp_client.get_column_names(self.last_query_handle)
if self.write_delimited:
@@ -737,7 +752,7 @@ class ImpalaShell(cmd.Cmd):
self.query_handle_closed = False
self.last_summary = time.time()
wait_to_finish = self.imp_client.wait_to_finish(self.last_query_handle,
self._periodic_wait_callback)
self._periodic_wait_callback)
# Reset the progress stream.
self.progress_stream.clear()