impala git commit: IMPALA-6441 addendum: fix reading rows from HS2 via Impyla

[mi...@apache.org]

Repository: impala
Updated Branches:
  refs/heads/master 3bfda3348 -> d49f629c4


IMPALA-6441 addendum: fix reading rows from HS2 via Impyla

When fetching explain output from HS2 using Impyla, rows come back in
lists of 1-tuples.

This patch exhibits the need to do end-to-end testing when the case
warrants. In this case, although the unit test for
http://gerrit.cloudera.org:8080/9141 passes, I neglected to make sure
this worked in the stress test. Mea culpa. It works now.

Change-Id: Id26d1db15c22a971dc1a346ad6d1df758306c3c5
Reviewed-on: http://gerrit.cloudera.org:8080/9146
Reviewed-by: Michael Brown <mi...@cloudera.com>
Tested-by: Impala Public Jenkins


Project: http://git-wip-us.apache.org/repos/asf/impala/repo
Commit: http://git-wip-us.apache.org/repos/asf/impala/commit/d49f629c
Tree: http://git-wip-us.apache.org/repos/asf/impala/tree/d49f629c
Diff: http://git-wip-us.apache.org/repos/asf/impala/diff/d49f629c

Branch: refs/heads/master
Commit: d49f629c447ea59ad73ceeb0547fde4d41c651d1
Parents: 3bfda33
Author: Michael Brown <mi...@cloudera.com>
Authored: Fri Jan 26 10:22:03 2018 -0800
Committer: Impala Public Jenkins <im...@gerrit.cloudera.org>
Committed: Thu Feb 1 19:50:52 2018 +0000

----------------------------------------------------------------------
 tests/stress/concurrent_select.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/impala/blob/d49f629c/tests/stress/concurrent_select.py
----------------------------------------------------------------------
diff --git a/tests/stress/concurrent_select.py b/tests/stress/concurrent_select.py
index 86e8978..e03c8b2 100755
--- a/tests/stress/concurrent_select.py
+++ b/tests/stress/concurrent_select.py
@@ -1384,7 +1384,8 @@ def estimate_query_mem_mb_usage(query, query_runner):
       return
     LOG.debug("Explaining query\n%s", query.sql)
     cursor.execute('EXPLAIN ' + query.sql)
-    explain_lines = cursor.fetchall()
+    explain_rows = cursor.fetchall()
+    explain_lines = [row[0] for row in explain_rows]
     mem_limit, units = match_memory_estimate(explain_lines)
     return parse_mem_to_mb(mem_limit, units)