You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues-all@impala.apache.org by "Tim Armstrong (Jira)" <ji...@apache.org> on 2019/09/10 00:50:00 UTC
[jira] [Updated] (IMPALA-5218) get exhaustive/ASAN build to work
[ https://issues.apache.org/jira/browse/IMPALA-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tim Armstrong updated IMPALA-5218:
----------------------------------
Priority: Minor (was: Major)
> get exhaustive/ASAN build to work
> ---------------------------------
>
> Key: IMPALA-5218
> URL: https://issues.apache.org/jira/browse/IMPALA-5218
> Project: IMPALA
> Issue Type: Improvement
> Components: Infrastructure
> Affects Versions: Impala 2.7.0, Impala 2.8.0
> Reporter: Alexander Behm
> Priority: Minor
> Attachments: jenkins_console.txt
>
>
> Running exhaustive under ASAN fails with the following errors in impalad.ERROR:
> {code}
> ==22229==ERROR: AddressSanitizer failed to allocate 0x6d000 (446464) bytes at address fe8b6160000 (errno: 12)
> ==22229==ERROR: AddressSanitizer failed to allocate 0xff000 (1044480) bytes at address fe8b1592000 (errno: 12)
> ==22229==ReserveShadowMemoryRange failed while trying to map 0x6d000 bytes. Perhaps you're using ulimit -v
> ==22229==ReserveShadowMemoryRange failed while trying to map 0xff000 bytes. Perhaps you're using ulimit -v
> ==22229==ERROR: AddressSanitizer failed to allocate 0x22000 (139264) bytes of LargeMmapAllocator (error code: 12)
> ERROR: Failed to mmap
> {code}
> Failures from the Jenkins console:
> {code}
> 15:57:39.773 [gw3] PASSED query_test/test_queries.py::TestQueries::test_union[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: avro/none]
> 15:57:39.773 query_test/test_queries.py::TestQueries::test_union[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: avro/none]
> 15:59:48.959 [gw2] PASSED query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/snap/block | enable_expr_rewrites: 0]
> 15:59:48.964 query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/bzip/block | enable_expr_rewrites: 0]
> 16:01:04.506 [gw0] FAILED query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/gzip/record]
> 16:01:04.508 query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/gzip/record]
> 16:01:04.512 [gw1] FAILED query_test/test_queries.py::TestQueries::test_subquery[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: rc/none]
> 16:01:04.514 query_test/test_queries.py::TestQueries::test_subquery[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: rc/def/block]
> 16:01:04.630 [gw2] FAILED query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/bzip/block | enable_expr_rewrites: 0]
> 16:01:04.630 query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/gzip/block | enable_expr_rewrites: 1]
> 16:01:04.797 [gw0] FAILED query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/gzip/record]
> 16:01:04.797 query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:04.797 [gw1] FAILED query_test/test_queries.py::TestQueries::test_subquery[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: rc/def/block]
> 16:01:04.797 query_test/test_queries.py::TestQueries::test_subquery[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: rc/def/block]
> 16:01:04.829 [gw2] FAILED query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/gzip/block | enable_expr_rewrites: 1]
> 16:01:04.829 query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/none | enable_expr_rewrites: 1]
> 16:01:04.946 [gw3] FAILED query_test/test_queries.py::TestQueries::test_union[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: avro/none]
> 16:01:04.946 query_test/test_queries.py::TestQueries::test_union[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: avro/none]
> 16:01:04.946 [gw0] FAILED query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:04.946 query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:05.061 [gw0] FAILED query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:05.074 query_test/test_queries.py::TestQueries::test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:05.075 [gw2] FAILED query_test/test_exprs.py::TestExprs::test_exprs[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/none | enable_expr_rewrites: 1] Traceback (most recent call last):
> 16:01:10.491 File "/usr/lib64/python2.6/logging/__init__.py", line 797, in emit
> 16:01:10.498 stream.write(fs % msg)
> 16:01:10.498 File "/data/jenkins/workspace/impala-private-build-and-test/repos/Impala/infra/python/env/lib/python2.6/site-packages/_pytest/capture.py", line 232, in write
> 16:01:10.503 Traceback (most recent call last):
> 16:01:10.503 File "/usr/lib64/python2.6/logging/__init__.py", line 797, in emit
> 16:01:10.503 stream.write(fs % msg)
> 16:01:10.503 File "/data/jenkins/workspace/impala-private-build-and-test/repos/Impala/infra/python/env/lib/python2.6/site-packages/_pytest/capture.py", line 232, in write
> 16:01:10.506 self.buffer.write(obj)
> 16:01:10.506 self.buffer.write(obj)
> 16:01:10.506 ValueError: I/O operation on closed file
> 16:01:10.506 ValueError: I/O operation on closed file
> 16:01:11.106 Traceback (most recent call last):
> 16:01:11.106 File "/usr/lib64/python2.6/logging/__init__.py", line 797, in emit
> 16:01:11.106 stream.write(fs % msg)
> 16:01:11.107 File "/data/jenkins/workspace/impala-private-build-and-test/repos/Impala/infra/python/env/lib/python2.6/site-packages/_pytest/capture.py", line 232, in write
> 16:01:11.107 self.buffer.write(obj)
> 16:01:11.109 ValueError: I/O operation on closed file
> 16:01:11.852
> 16:01:11.852
> 16:01:11.852 generated xml file: /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/logs/ee_tests/results/TEST-impala-parallel.xml
> 16:01:11.854 =========================== short test summary info ============================
> 16:01:11.910 =================================== FAILURES ===================================
> 16:01:11.910 TestQueries.test_analytic_fns[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/gzip/record]
> 16:01:11.910 [gw0] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.910 query_test/test_queries.py:61: in test_analytic_fns
> 16:01:11.910 self.run_test_case('QueryTest/analytic-fns', vector)
> 16:01:11.910 common/impala_test_suite.py:359: in run_test_case
> 16:01:11.910 result = self.__execute_query(target_impalad_client, query, user=user)
> 16:01:11.910 common/impala_test_suite.py:567: in __execute_query
> 16:01:11.910 return impalad_client.execute(query, user=user)
> 16:01:11.910 common/impala_connection.py:160: in execute
> 16:01:11.910 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.910 beeswax/impala_beeswax.py:191: in execute
> 16:01:11.910 result = self.fetch_results(query_string, handle)
> 16:01:11.910 beeswax/impala_beeswax.py:394: in fetch_results
> 16:01:11.910 exec_result = self.__fetch_results(query_handle, max_rows)
> 16:01:11.910 beeswax/impala_beeswax.py:405: in __fetch_results
> 16:01:11.911 results = self.__do_rpc(lambda: self.imp_service.fetch(handle, False, fetch_rows))
> 16:01:11.911 beeswax/impala_beeswax.py:461: in __do_rpc
> 16:01:11.911 raise ImpalaBeeswaxException(self.__build_error_message(e), e)
> 16:01:11.911 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.911 E INNER EXCEPTION: <class 'thrift.transport.TTransport.TTransportException'>
> 16:01:11.911 E MESSAGE: TSocket read 0 bytes
> 16:01:11.911 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 use functional_seq_record_gzip;
> 16:01:11.911
> 16:01:11.911 SET disable_codegen=False;
> 16:01:11.911 SET abort_on_error=1;
> 16:01:11.911 SET exec_single_node_rows_threshold=0;
> 16:01:11.911 SET batch_size=0;
> 16:01:11.911 SET num_nodes=0;
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select year, month,
> 16:01:11.911 count(int_col) over (partition by year, month),
> 16:01:11.911 avg(int_col) over (partition by year, month),
> 16:01:11.911 avg(timestamp_col) over (partition by year, month),
> 16:01:11.911 min(string_col) over (partition by year, month),
> 16:01:11.911 max(string_col) over (partition by year, month)
> 16:01:11.911 from alltypessmall
> 16:01:11.911 where id % 4 = 0 and month != 1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select int_col,
> 16:01:11.911 count(int_col) over ()
> 16:01:11.911 from alltypessmall
> 16:01:11.911 where id % 4 = 0 and month = 1
> 16:01:11.911 order by int_col;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select tinyint_col,
> 16:01:11.911 count(int_col) over (order by tinyint_col)
> 16:01:11.911 from alltypessmall
> 16:01:11.911 where month = 1 and tinyint_col < 5;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select tinyint_col, smallint_col, int_col,
> 16:01:11.911 sum(smallint_col) over (order by tinyint_col nulls first)
> 16:01:11.911 from alltypesagg
> 16:01:11.911 where year = 2010 and month = 1 and day = 4 and id <= 3030 and bool_col = true
> 16:01:11.911 order by tinyint_col, id, smallint_col, int_col;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select tinyint_col, smallint_col,
> 16:01:11.911 sum(smallint_col) over (partition by tinyint_col order by smallint_col),
> 16:01:11.911 sum(smallint_col) over (partition by tinyint_col order by smallint_col
> 16:01:11.911 rows between unbounded preceding and 1 following),
> 16:01:11.911 sum(smallint_col) over (partition by tinyint_col order by smallint_col
> 16:01:11.911 rows between 1 following and 2 following)
> 16:01:11.911 from alltypesagg
> 16:01:11.911 where year = 2010 and month = 1 and day = 4 and id <= 3200
> 16:01:11.911 and (smallint_col < 50 or smallint_col is NULL)
> 16:01:11.911 and (tinyint_col = 1 or tinyint_col is NULL);
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select
> 16:01:11.911 sum(tinyint_col) over (order by id nulls last rows between 1 preceding and 1 preceding),
> 16:01:11.911 sum(tinyint_col) over (order by id nulls last rows between 1 preceding and current row),
> 16:01:11.911 sum(tinyint_col) over (order by id nulls last rows between current row and 1 following),
> 16:01:11.911 sum(tinyint_col) over (order by id nulls last rows between 1 following and 1 following)
> 16:01:11.911 from alltypesagg where id < 30 and (tinyint_col is null or tinyint_col < 6);
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select year, month, bool_col, tinyint_col,
> 16:01:11.911 count(id) over (partition by year, month order by bool_col, tinyint_col)
> 16:01:11.911 from alltypes
> 16:01:11.911 where tinyint_col < 2 and month < 3 and (id % 100 < 10)
> 16:01:11.911 order by year, month, bool_col, tinyint_col;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select count(*) from
> 16:01:11.911 (select year, month, bool_col, tinyint_col,
> 16:01:11.911 count(id) over (partition by year, month order by bool_col, tinyint_col)
> 16:01:11.911 from alltypes
> 16:01:11.911 where tinyint_col < 2 and month < 3 and (id % 100 < 10)
> 16:01:11.911 limit 7) v;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select (month % 2), int_col,
> 16:01:11.911 sum(int_col) over (partition by (month % 2)
> 16:01:11.911 order by int_col rows between unbounded preceding and current row)
> 16:01:11.911 from alltypestiny;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select
> 16:01:11.911 count(tinyint_col) over (partition by bool_col order by tinyint_col
> 16:01:11.911 rows between unbounded preceding and 1 preceding),
> 16:01:11.911 sum(tinyint_col) over (partition by bool_col order by tinyint_col
> 16:01:11.911 rows between unbounded preceding and 1 following),
> 16:01:11.911 sum(tinyint_col) over (partition by bool_col order by tinyint_col
> 16:01:11.911 rows between unbounded preceding and 3 preceding),
> 16:01:11.911 sum(tinyint_col) over (partition by bool_col order by tinyint_col
> 16:01:11.911 rows between unbounded preceding and 20 following),
> 16:01:11.911 sum(tinyint_col) over (partition by bool_col order by tinyint_col
> 16:01:11.911 rows between unbounded preceding and 20 preceding)
> 16:01:11.911 from alltypesagg where id <= 10 and day = 1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select tinyint_col, int_col, bigint_col,
> 16:01:11.911 count(bigint_col)
> 16:01:11.911 over(partition by tinyint_col, bigint_col order by int_col desc
> 16:01:11.911 rows between unbounded preceding and 1 following),
> 16:01:11.911 max(tinyint_col)
> 16:01:11.911 over(partition by bigint_col, tinyint_col order by int_col desc
> 16:01:11.911 rows between unbounded preceding and 1 following),
> 16:01:11.911 min(int_col)
> 16:01:11.911 over(partition by bigint_col, tinyint_col order by int_col desc
> 16:01:11.911 rows between unbounded preceding and 2 following),
> 16:01:11.911 max(int_col)
> 16:01:11.911 over(partition by bigint_col, tinyint_col order by int_col asc
> 16:01:11.911 rows between unbounded preceding and 2 following),
> 16:01:11.911 sum(int_col)
> 16:01:11.911 over(partition by tinyint_col order by int_col desc
> 16:01:11.911 rows between unbounded preceding and 2 following)
> 16:01:11.911 from functional.alltypesagg
> 16:01:11.911 where id < 20;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select bool_col,
> 16:01:11.911 sum(min(int_col))
> 16:01:11.911 over(partition by min(tinyint_col) order by max(int_col)
> 16:01:11.911 rows between unbounded preceding and 1 following),
> 16:01:11.911 max(sum(bigint_col))
> 16:01:11.911 over(partition by min(tinyint_col) order by max(int_col)
> 16:01:11.911 rows between unbounded preceding and 1 following),
> 16:01:11.911 min(sum(bigint_col))
> 16:01:11.911 over(partition by min(tinyint_col) order by sum(int_col)
> 16:01:11.911 rows between unbounded preceding and 4 following)
> 16:01:11.911 from functional.alltypes
> 16:01:11.911 group by 1
> 16:01:11.911 order by 1, 2, 3;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select DISTINCT t1.c1 FROM
> 16:01:11.911 (SELECT MAX(smallint_col) OVER (PARTITION BY year ORDER BY id DESC) AS c1
> 16:01:11.911 FROM alltypesagg) t1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 with with_1 AS (
> 16:01:11.911 SELECT RANK() OVER (ORDER BY t1.id) AS int_col_1
> 16:01:11.911 FROM alltypesagg t1)
> 16:01:11.911 SELECT COUNT(t1.int_col_1) AS int_col_1
> 16:01:11.911 FROM with_1 t1
> 16:01:11.911 WHERE t1.int_col_1 IS NULL;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select tinyint_col, id,
> 16:01:11.911 row_number() over (order by tinyint_col, id) total_order,
> 16:01:11.911 row_number() over (partition by tinyint_col order by id) partitioned_order,
> 16:01:11.911 first_value(id) over (partition by tinyint_col order by id),
> 16:01:11.911 first_value(cast(id as string)) over (partition by tinyint_col order by id),
> 16:01:11.911 last_value(id) over (partition by tinyint_col order by id),
> 16:01:11.911 last_value(cast(id as string)) over (partition by tinyint_col order by id),
> 16:01:11.911 last_value(id) over (partition by tinyint_col order by id
> 16:01:11.911 rows between unbounded preceding and unbounded following)
> 16:01:11.911 from alltypes where id < 25 order by tinyint_col, id;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select bool_col, id,
> 16:01:11.911 lag(id, 2, -12345) over (partition by bool_col order by id),
> 16:01:11.911 lead(id, 2, -12345) over (partition by bool_col order by id)
> 16:01:11.911 from alltypestiny;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select year, month, bool_col, tinyint_col,
> 16:01:11.911 rank() over (partition by year, month order by bool_col, tinyint_col),
> 16:01:11.911 dense_rank() over (partition by year, month order by bool_col, tinyint_col)
> 16:01:11.911 from alltypes
> 16:01:11.911 where tinyint_col < 2 and month < 3 and (id % 100 < 10)
> 16:01:11.911 order by year, month, bool_col, tinyint_col;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select bool_col, a, b, a+b from
> 16:01:11.911 (select
> 16:01:11.911 bool_col,
> 16:01:11.911 count(int_col) over() a,
> 16:01:11.911 sum(int_col + bigint_col) over(partition by bool_col) b
> 16:01:11.911 from
> 16:01:11.911 (select * from functional.alltypes where id < 20) v1) v2
> 16:01:11.911 order by 1, 2, 3;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select 1 a, min(id) over (partition by int_col)
> 16:01:11.911 from functional.alltypes where id < 5
> 16:01:11.911 union distinct
> 16:01:11.911 select 2, max(id) over (partition by bool_col)
> 16:01:11.911 from functional.alltypessmall where id >= 5 and id <= 10
> 16:01:11.911 union all
> 16:01:11.911 (select 3, sum(bigint_col) over (partition by int_col order by id)
> 16:01:11.911 from functional.alltypestiny where bool_col = false)
> 16:01:11.911 order by 1, 2 desc nulls first;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id, int_col, bool_col from functional.alltypestiny t1
> 16:01:11.911 where int_col in
> 16:01:11.911 (select min(bigint_col) over(partition by bool_col)
> 16:01:11.911 from functional.alltypessmall t2 where t2.id < 10);
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select * from
> 16:01:11.911 (select bool_col, tinyint_col,
> 16:01:11.911 sum(tinyint_col) over (partition by bool_col order by tinyint_col
> 16:01:11.911 rows between unbounded preceding and 1 following) a
> 16:01:11.911 from alltypesagg where id <= 10 and day = 1) v
> 16:01:11.911 where
> 16:01:11.911 v.tinyint_col * 3 > v.a and
> 16:01:11.911 cast(v.a as boolean) = v.bool_col and
> 16:01:11.911 v.a is not null;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and 3 preceding) c1,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and 2 preceding) c2,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and 1 preceding) c3,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and current row) c4,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and 1 following) c5,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and 2 following) c6,
> 16:01:11.911 count(id) over (order by id rows between 3 preceding and 3 following) c7,
> 16:01:11.911 count(id) over (order by id rows between 2 preceding and 3 following) c8,
> 16:01:11.911 count(id) over (order by id rows between 1 preceding and 3 following) c9,
> 16:01:11.911 count(id) over (order by id rows between current row and 3 following) c10,
> 16:01:11.911 count(id) over (order by id rows between 1 following and 3 following) c11,
> 16:01:11.911 count(id) over (order by id rows between 2 following and 3 following) c12,
> 16:01:11.911 count(id) over (order by id rows between 3 following and 3 following) c13
> 16:01:11.911 from alltypes where id < 8;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id,
> 16:01:11.911 sum(int_col) over (order by id rows between 1 preceding and 1 following),
> 16:01:11.911 sum(double_col) over (order by id rows between 3 preceding and 2 preceding),
> 16:01:11.911 avg(int_col) over (order by id rows between 1 preceding and 1 following),
> 16:01:11.911 avg(double_col) over (order by id rows between 3 preceding and 2 preceding),
> 16:01:11.911 avg(timestamp_col) over (order by id rows between 2 following and 3 following)
> 16:01:11.911 from alltypes where id < 8;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select tinyint_col, int_col,
> 16:01:11.911 sum(int_col) over (partition by tinyint_col order by int_col nulls last rows between 2 following and 3 following),
> 16:01:11.911 sum(int_col) over (partition by tinyint_col order by int_col nulls last rows between 2 following and 10 following),
> 16:01:11.911 sum(int_col) over (partition by tinyint_col order by int_col nulls last rows between 6 following and 100 following)
> 16:01:11.911 from alltypesagg
> 16:01:11.911 where (tinyint_col is NULL or tinyint_col < 3) and id < 60;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select
> 16:01:11.911 count(int_col) over (order by bigint_col rows between 95 preceding and 40 following)
> 16:01:11.911 from alltypestiny;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select count(distinct t1.c1) from
> 16:01:11.911 (select count(id) over (order by id rows between 550 preceding and 550 following) c1
> 16:01:11.911 from alltypesagg) t1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select count(distinct t1.c1) from
> 16:01:11.911 (select count(id) over (order by id rows between 1050 preceding and 2 following) c1
> 16:01:11.911 from alltypesagg) t1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select count(distinct t1.c1) from
> 16:01:11.911 (select count(id) over (order by id rows between 1050 preceding and 500 preceding) c1
> 16:01:11.911 from alltypesagg) t1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select count(distinct t1.c1) from
> 16:01:11.911 (select count(id) over (order by id rows between 2 following and 1050 following) c1
> 16:01:11.911 from alltypesagg) t1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select count(distinct t1.c1) from
> 16:01:11.911 (select count(id) over (order by id rows between 500 following and 1050 following) c1
> 16:01:11.911 from alltypesagg) t1;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select (tinyint_col % 4), id,
> 16:01:11.911 count(id) over (partition by (tinyint_col % 4) order by id
> 16:01:11.911 rows between 3 following and 10 following)
> 16:01:11.911 from alltypes where id < 20
> 16:01:11.911 order by (tinyint_col % 4), id;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select sum(t2.int_col_1) from
> 16:01:11.911 (select SUM(t1.int_col) OVER (PARTITION BY t1.smallint_col ORDER BY t1.day, t1.int_col
> 16:01:11.911 ROWS 7 PRECEDING) AS int_col_1
> 16:01:11.911 FROM alltypesagg t1 ) t2;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select cast(floor(id/3) as int), tinyint_col,
> 16:01:11.911 first_value(tinyint_col) over (partition by cast(floor(id/3) as int) order by tinyint_col nulls first),
> 16:01:11.911 first_value(cast(tinyint_col as string)) over (partition by cast(floor(id/3) as int) order by cast(tinyint_col as string) nulls first),
> 16:01:11.911 last_value(tinyint_col) over (partition by cast(floor(id/3) as int) order by tinyint_col nulls first),
> 16:01:11.911 last_value(cast(tinyint_col as string)) over (partition by cast(floor(id/3) as int) order by cast(tinyint_col as string) nulls first)
> 16:01:11.911 from alltypesagg where id < 50 and (tinyint_col is null or tinyint_col < 4);
> 16:01:11.911
> 16:01:11.911 TestQueries.test_subquery[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: rc/none]
> 16:01:11.911 [gw1] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.911 query_test/test_queries.py:110: in test_subquery
> 16:01:11.911 self.run_test_case('QueryTest/subquery', vector)
> 16:01:11.911 common/impala_test_suite.py:359: in run_test_case
> 16:01:11.911 result = self.__execute_query(target_impalad_client, query, user=user)
> 16:01:11.911 common/impala_test_suite.py:567: in __execute_query
> 16:01:11.911 return impalad_client.execute(query, user=user)
> 16:01:11.911 common/impala_connection.py:160: in execute
> 16:01:11.911 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.911 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.911 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.911 beeswax/impala_beeswax.py:339: in __execute_query
> 16:01:11.911 self.wait_for_completion(handle)
> 16:01:11.911 beeswax/impala_beeswax.py:351: in wait_for_completion
> 16:01:11.911 query_state = self.get_state(query_handle)
> 16:01:11.911 beeswax/impala_beeswax.py:368: in get_state
> 16:01:11.911 return self.__do_rpc(lambda: self.imp_service.get_state(query_handle))
> 16:01:11.911 beeswax/impala_beeswax.py:465: in __do_rpc
> 16:01:11.911 raise ImpalaBeeswaxException(self.__build_error_message(u), u)
> 16:01:11.911 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.911 E INNER EXCEPTION: <class 'socket.error'>
> 16:01:11.911 E MESSAGE: [Errno 104] Connection reset by peer
> 16:01:11.911 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 use functional_rc;
> 16:01:11.911
> 16:01:11.911 SET disable_codegen=False;
> 16:01:11.911 SET abort_on_error=1;
> 16:01:11.911 SET exec_single_node_rows_threshold=100;
> 16:01:11.911 SET batch_size=0;
> 16:01:11.911 SET num_nodes=0;
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select a.id, a.int_col, a.string_col
> 16:01:11.911 from functional.alltypessmall a
> 16:01:11.911 where a.id in (select id from functional.alltypestiny where bool_col = false)
> 16:01:11.911 and a.id < 5;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select a.id, a.int_col, a.string_col
> 16:01:11.911 from functional.alltypes a
> 16:01:11.911 where a.int_col in (select int_col from functional.alltypesagg where int_col is not null)
> 16:01:11.911 and a.id < 5;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select a.id, a.int_col, a.string_col
> 16:01:11.911 from functional.alltypes a
> 16:01:11.911 where a.id in (select int_col from functional.alltypesagg where int_col is null)
> 16:01:11.911 and a.id < 5;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id, year, month
> 16:01:11.911 from functional.alltypessmall
> 16:01:11.911 where id not in (select id from functional.alltypestiny where bool_col = false)
> 16:01:11.911 and id < 5;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id
> 16:01:11.911 from functional.alltypestiny
> 16:01:11.911 where int_col not in (select int_col from functional.alltypesagg where int_col is null)
> 16:01:11.911 and id < 10;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id
> 16:01:11.911 from functional.alltypestiny
> 16:01:11.911 where int_col not in (select int_col from functional.alltypesagg);
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id, int_col
> 16:01:11.911 from functional.alltypestiny
> 16:01:11.911 where int_col not in (select int_col from functional.alltypesagg where id < 0)
> 16:01:11.911 order by id;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id, int_col
> 16:01:11.911 from functional.alltypesagg
> 16:01:11.911 where int_col not in (select int_col from functional.alltypestiny where id < 0)
> 16:01:11.911 and id < 5
> 16:01:11.911 order by id;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id
> 16:01:11.911 from functional.alltypesagg
> 16:01:11.911 where int_col is null and
> 16:01:11.911 int_col not in (select int_col from functional.alltypestiny);
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select id, int_col
> 16:01:11.911 from functional.alltypesagg
> 16:01:11.911 where int_col is null and
> 16:01:11.911 int_col not in (select int_col from functional.alltypestiny where id < 0)
> 16:01:11.911 and id < 10
> 16:01:11.911 order by id;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select s.id, s.bool_col, s.int_col, s.date_string_col
> 16:01:11.911 from functional.alltypessmall s
> 16:01:11.911 where s.id in (select id from functional.alltypestiny t where t.int_col = s.int_col)
> 16:01:11.911 and s.bool_col = false;
> 16:01:11.911
> 16:01:11.911 -- executing against localhost:21000
> 16:01:11.911 select s.id, s.bool_col, s.int_col
> 16:01:11.911 from functional.alltypessmall s
> 16:01:11.912 where s.id not in
> 16:01:11.912 (select id
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where s.int_col = t.int_col and t.bool_col = false)
> 16:01:11.912 and s.id < 5
> 16:01:11.912 order by s.id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where t.int_col not in
> 16:01:11.912 (select int_col from functional.alltypes a where t.id = a.id and a.bigint_col < 0)
> 16:01:11.912 and id < 5
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where t.int_col not in
> 16:01:11.912 (select int_col from functional.alltypesagg a where int_col is null and a.id = t.id)
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col
> 16:01:11.912 from functional.alltypesagg a
> 16:01:11.912 where a.int_col not in
> 16:01:11.912 (select int_col from functional.alltypesagg b where a.id = b.id)
> 16:01:11.912 and id < 10;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col
> 16:01:11.912 from functional.alltypesagg a
> 16:01:11.912 where int_col not in
> 16:01:11.912 (select int_col from functional.alltypestiny t where a.id = t.id)
> 16:01:11.912 and bigint_col = 10
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col, bigint_col
> 16:01:11.912 from functional.alltypesagg a
> 16:01:11.912 where int_col not in
> 16:01:11.912 (select int_col from alltypestiny t where a.id = t.id and t.bigint_col < 0)
> 16:01:11.912 and bigint_col = 10
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col, bigint_col
> 16:01:11.912 from alltypesagg a
> 16:01:11.912 where int_col not in (select int_col from alltypesagg t where a.id = t.id)
> 16:01:11.912 and int_col is null;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(distinct id)
> 16:01:11.912 from alltypesagg t1
> 16:01:11.912 where t1.day not in
> 16:01:11.912 (select tt1.tinyint_col as tinyint_col_1
> 16:01:11.912 from alltypesagg tt1
> 16:01:11.912 where t1.smallint_col = tt1.smallint_col);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*)
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where exists (select * from functional.alltypessmall s where t.int_col = s.int_col)
> 16:01:11.912 and id < 4;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col
> 16:01:11.912 from functional.alltypessmall t
> 16:01:11.912 where not exists (select 1 from functional.alltypestiny s where t.id = s.id)
> 16:01:11.912 and month = 1 and int_col < 5
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where exists (select 1 from functional.alltypessmall where bool_col = false)
> 16:01:11.912 and bool_col = true
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select 1
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where exists (select null from functional.alltypessmall where id < 0)
> 16:01:11.912 and t.id > 0;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where not exists (select 1 from functional.alltypessmall where bool_col = false)
> 16:01:11.912 and bool_col = true;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select 1
> 16:01:11.912 from functional.alltypestiny t
> 16:01:11.912 where not exists (select null from functional.alltypessmall where id < 0)
> 16:01:11.912 and t.id > 0;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from
> 16:01:11.912 functional.alltypessmall t
> 16:01:11.912 where t.id < (select max(id) from functional.alltypestiny)
> 16:01:11.912 and t.bool_col = true;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col, year, month
> 16:01:11.912 from functional.alltypessmall
> 16:01:11.912 where int_col = (select count(*) from functional.alltypestiny)
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, int_col, year, month
> 16:01:11.912 from functional.alltypessmall s
> 16:01:11.912 where s.int_col = (select count(*) from functional.alltypestiny t where s.id = t.id)
> 16:01:11.912 order by id;
> 16:01:11.912
> 16:01:11.912 TestExprs.test_exprs[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/bzip/block | enable_expr_rewrites: 0]
> 16:01:11.912 [gw2] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.912 query_test/test_exprs.py:58: in test_exprs
> 16:01:11.912 self.run_test_case('QueryTest/exprs', vector)
> 16:01:11.912 common/impala_test_suite.py:359: in run_test_case
> 16:01:11.912 result = self.__execute_query(target_impalad_client, query, user=user)
> 16:01:11.912 common/impala_test_suite.py:567: in __execute_query
> 16:01:11.912 return impalad_client.execute(query, user=user)
> 16:01:11.912 common/impala_connection.py:160: in execute
> 16:01:11.912 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.912 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:339: in __execute_query
> 16:01:11.912 self.wait_for_completion(handle)
> 16:01:11.912 beeswax/impala_beeswax.py:351: in wait_for_completion
> 16:01:11.912 query_state = self.get_state(query_handle)
> 16:01:11.912 beeswax/impala_beeswax.py:368: in get_state
> 16:01:11.912 return self.__do_rpc(lambda: self.imp_service.get_state(query_handle))
> 16:01:11.912 beeswax/impala_beeswax.py:465: in __do_rpc
> 16:01:11.912 raise ImpalaBeeswaxException(self.__build_error_message(u), u)
> 16:01:11.912 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.912 E INNER EXCEPTION: <class 'socket.error'>
> 16:01:11.912 E MESSAGE: [Errno 104] Connection reset by peer
> 16:01:11.912 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 use functional_text_bzip;
> 16:01:11.912
> 16:01:11.912 SET batch_size=0;
> 16:01:11.912 SET num_nodes=0;
> 16:01:11.912 SET disable_codegen=True;
> 16:01:11.912 SET abort_on_error=1;
> 16:01:11.912 SET exec_single_node_rows_threshold=0;
> 16:01:11.912 SET enable_expr_rewrites=0;
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select smallint_col, int_col, (cast("1970-01-01" as timestamp) + interval smallint_col days)
> 16:01:11.912 from functional.alltypes where smallint_col = 1 limit 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select ADD_MONTHS(cast('2013-02-18 16:46:00.01' as timestamp), 1);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select b.unit, extract(a.ts, b.unit) from
> 16:01:11.912 (values(cast('2013-02-18 16:46:00.01' as timestamp) ts)) a
> 16:01:11.912 cross join
> 16:01:11.912 (values('year' unit), ('month'), ('day'), ('hour'), ('minute'), ('second'),
> 16:01:11.912 ('millisecond'), ('epoch' )) b;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select EXTRACT(timestamp_col, 'yEar'), EXTRACT(timestamp_col, 'MilliSECond')
> 16:01:11.912 from alltypesagg order by id limit 5;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col is null;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col is not null;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col = 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where smallint_col = 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where int_col = 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where bigint_col = 10;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where float_col = cast(1.1 as float);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col = 10.1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where date_string_col = '01/01/10';
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col <> 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where smallint_col <> 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where int_col <> 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where bigint_col <> 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where float_col <> cast(1.1 as float);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col <> 10.1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col < 2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where smallint_col < 2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where int_col < 2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where bigint_col < 20;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where float_col < 2.2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col < 20.2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col > 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where smallint_col > 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where int_col > 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where bigint_col > 10;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where float_col > cast(1.1 as float);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col > 10.1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col <= 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where smallint_col <= 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where int_col <= 1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where bigint_col <= 10;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where float_col <= cast(1.1 as float);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col <= 10.1;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where tinyint_col >= 2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where smallint_col >= 2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where int_col >= 2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where bigint_col >= 20;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where float_col >= 2.2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col >= 20.2;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col >= 20.2 and cast(double_col as double) = cast(double_col as real);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select count(*) from alltypesagg where double_col >= 20.2 and cast(double_col as int) = cast(double_col as integer);
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select
> 16:01:11.912 SUM(tinyint_col) + SUM(smallint_col),
> 16:01:11.912 SUM(tinyint_col + smallint_col),
> 16:01:11.912 SUM(tinyint_col) + SUM(smallint_col) + SUM(int_col),
> 16:01:11.912 SUM(tinyint_col + smallint_col + int_col),
> 16:01:11.912 SUM(tinyint_col) + SUM(smallint_col) + SUM(int_col) + SUM(bigint_col),
> 16:01:11.912 SUM(tinyint_col + smallint_col + int_col + bigint_col),
> 16:01:11.912 ROUND(SUM(tinyint_col) + SUM(smallint_col) + SUM(int_col) + SUM(bigint_col) +
> 16:01:11.912 SUM(float_col), 4),
> 16:01:11.912 ROUND(SUM(tinyint_col + smallint_col + int_col + bigint_col + float_col), 4),
> 16:01:11.912 ROUND(SUM(tinyint_col) + SUM(smallint_col) + SUM(int_col) + SUM(bigint_col) +
> 16:01:11.912 SUM(float_col) + SUM(double_col), 4),
> 16:01:11.912 ROUND(SUM(tinyint_col + smallint_col + int_col + bigint_col + float_col + double_col), 4)
> 16:01:11.912 from alltypesaggnonulls;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select
> 16:01:11.912 -1 * SUM(tinyint_col) - SUM(smallint_col),
> 16:01:11.912 SUM(-1 * tinyint_col - smallint_col),
> 16:01:11.912 -1 * SUM(tinyint_col) - SUM(smallint_col) - SUM(int_col),
> 16:01:11.912 SUM(-1 * tinyint_col - smallint_col - int_col),
> 16:01:11.912 -1 * SUM(tinyint_col) - SUM(smallint_col) - SUM(int_col) - SUM(bigint_col),
> 16:01:11.912 SUM(-1 * tinyint_col - smallint_col - int_col - bigint_col),
> 16:01:11.912 ROUND(-1 * SUM(tinyint_col) - SUM(smallint_col) - SUM(int_col) -
> 16:01:11.912 SUM(bigint_col) - SUM(float_col), 4),
> 16:01:11.912 ROUND(SUM(-1 * tinyint_col - smallint_col - int_col - bigint_col - float_col), 4),
> 16:01:11.912 ROUND(-1 * SUM(tinyint_col) - SUM(smallint_col) - SUM(int_col) -
> 16:01:11.912 SUM(bigint_col) - SUM(float_col) - SUM(double_col), 4),
> 16:01:11.912 ROUND(SUM(-1 * tinyint_col - smallint_col - int_col -
> 16:01:11.912 bigint_col - float_col - double_col), 4)
> 16:01:11.912 from alltypesaggnonulls;
> 16:01:11.912
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select
> 16:01:11.912 MAX(tinyint_col) * MAX(smallint_col),
> 16:01:11.912 MAX(tinyint_col * smallint_col),
> 16:01:11.912 MAX(tinyint_col) * MAX(smallint_col) * MAX(int_col),
> 16:01:11.912 MAX(tinyint_col * smallint_col * int_col),
> 16:01:11.912 MAX(tinyint_col) * MAX(smallint_col) * MAX(int_col) * MAX(bigint_col),
> 16:01:11.912 MAX(tinyint_col * smallint_col * int_col * bigint_col),
> 16:01:11.912 ROUND(MAX(tinyint_col) * MAX(smallint_col) * MAX(int_col) *
> 16:01:11.912 MAX(bigint_col) * MAX(float_col), 4),
> 16:01:11.912 ROUND(MAX(tinyint_col * smallint_col * int_col * bigint_col * float_col), 4),
> 16:01:11.912 ROUND(MAX(tinyint_col) * MAX(smallint_col) * MAX(int_col) *
> 16:01:11.912 MAX(bigint_col) * MAX(float_col) * MAX(double_col), 4),
> 16:01:11.912 ROUND(MAX(tinyint_col * smallint_col * int_col * bigint_col * float_col * double_col), 4)
> 16:01:11.912 from alltypesaggnonulls;
> 16:01:11.912
> 16:01:11.912 TestQueries.test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/gzip/record]
> 16:01:11.912 [gw0] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.912 query_test/test_queries.py:61: in test_analytic_fns
> 16:01:11.912 self.run_test_case('QueryTest/analytic-fns', vector)
> 16:01:11.912 common/impala_test_suite.py:307: in run_test_case
> 16:01:11.912 table_format_info, use_db, pytest.config.option.scale_factor)
> 16:01:11.912 common/impala_test_suite.py:452: in change_database
> 16:01:11.912 impala_client.execute(query)
> 16:01:11.912 common/impala_connection.py:160: in execute
> 16:01:11.912 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.912 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:337: in __execute_query
> 16:01:11.912 handle = self.execute_query_async(query_string, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:333: in execute_query_async
> 16:01:11.912 return self.__do_rpc(lambda: self.imp_service.query(query,))
> 16:01:11.912 beeswax/impala_beeswax.py:454: in __do_rpc
> 16:01:11.912 raise ImpalaBeeswaxException("Not connected", None)
> 16:01:11.912 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.912 E Not connected
> 16:01:11.912 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 use functional_seq_record_gzip;
> 16:01:11.912
> 16:01:11.912 TestQueries.test_subquery[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 100, 'batch_size': 0, 'num_nodes': 0} | table_format: rc/def/block]
> 16:01:11.912 [gw1] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.912 query_test/test_queries.py:110: in test_subquery
> 16:01:11.912 self.run_test_case('QueryTest/subquery', vector)
> 16:01:11.912 common/impala_test_suite.py:307: in run_test_case
> 16:01:11.912 table_format_info, use_db, pytest.config.option.scale_factor)
> 16:01:11.912 common/impala_test_suite.py:452: in change_database
> 16:01:11.912 impala_client.execute(query)
> 16:01:11.912 common/impala_connection.py:160: in execute
> 16:01:11.912 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.912 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:337: in __execute_query
> 16:01:11.912 handle = self.execute_query_async(query_string, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:333: in execute_query_async
> 16:01:11.912 return self.__do_rpc(lambda: self.imp_service.query(query,))
> 16:01:11.912 beeswax/impala_beeswax.py:465: in __do_rpc
> 16:01:11.912 raise ImpalaBeeswaxException(self.__build_error_message(u), u)
> 16:01:11.912 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.912 E INNER EXCEPTION: <class 'socket.error'>
> 16:01:11.912 E MESSAGE: [Errno 32] Broken pipe
> 16:01:11.912 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 use functional_rc_def;
> 16:01:11.912
> 16:01:11.912 TestExprs.test_exprs[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/gzip/block | enable_expr_rewrites: 1]
> 16:01:11.912 [gw2] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.912 query_test/test_exprs.py:58: in test_exprs
> 16:01:11.912 self.run_test_case('QueryTest/exprs', vector)
> 16:01:11.912 common/impala_test_suite.py:307: in run_test_case
> 16:01:11.912 table_format_info, use_db, pytest.config.option.scale_factor)
> 16:01:11.912 common/impala_test_suite.py:452: in change_database
> 16:01:11.912 impala_client.execute(query)
> 16:01:11.912 common/impala_connection.py:160: in execute
> 16:01:11.912 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.912 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:337: in __execute_query
> 16:01:11.912 handle = self.execute_query_async(query_string, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:333: in execute_query_async
> 16:01:11.912 return self.__do_rpc(lambda: self.imp_service.query(query,))
> 16:01:11.912 beeswax/impala_beeswax.py:465: in __do_rpc
> 16:01:11.912 raise ImpalaBeeswaxException(self.__build_error_message(u), u)
> 16:01:11.912 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.912 E INNER EXCEPTION: <class 'socket.error'>
> 16:01:11.912 E MESSAGE: [Errno 32] Broken pipe
> 16:01:11.912 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 use functional_text_gzip;
> 16:01:11.912
> 16:01:11.912 TestQueries.test_union[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: avro/none]
> 16:01:11.912 [gw3] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.912 query_test/test_queries.py:77: in test_union
> 16:01:11.912 self.run_test_case('QueryTest/union', vector)
> 16:01:11.912 common/impala_test_suite.py:359: in run_test_case
> 16:01:11.912 result = self.__execute_query(target_impalad_client, query, user=user)
> 16:01:11.912 common/impala_test_suite.py:567: in __execute_query
> 16:01:11.912 return impalad_client.execute(query, user=user)
> 16:01:11.912 common/impala_connection.py:160: in execute
> 16:01:11.912 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.912 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.912 beeswax/impala_beeswax.py:339: in __execute_query
> 16:01:11.912 self.wait_for_completion(handle)
> 16:01:11.912 beeswax/impala_beeswax.py:351: in wait_for_completion
> 16:01:11.912 query_state = self.get_state(query_handle)
> 16:01:11.912 beeswax/impala_beeswax.py:368: in get_state
> 16:01:11.912 return self.__do_rpc(lambda: self.imp_service.get_state(query_handle))
> 16:01:11.912 beeswax/impala_beeswax.py:465: in __do_rpc
> 16:01:11.912 raise ImpalaBeeswaxException(self.__build_error_message(u), u)
> 16:01:11.912 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.912 E INNER EXCEPTION: <class 'socket.error'>
> 16:01:11.912 E MESSAGE: [Errno 104] Connection reset by peer
> 16:01:11.912 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 use functional_avro;
> 16:01:11.912
> 16:01:11.912 SET disable_codegen=False;
> 16:01:11.912 SET abort_on_error=1;
> 16:01:11.912 SET exec_single_node_rows_threshold=0;
> 16:01:11.912 SET batch_size=10;
> 16:01:11.912 SET num_nodes=0;
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1 and id = 0 limit 1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1 order by int_col limit 1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2 and id = 2 limit 1;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1 order by id limit 3-2
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1 order by int_col limit 1*1*1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2 order by id limit 1&1;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union distinct
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union distinct
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select 0,true,0,0,0,0,0,0,'01/01/09','0',cast('2009-01-01 00:00:00' as timestamp), 2009,1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select 1,false,1,1,1,10,1.1,10.1,'01/01/09','1',cast('2009-01-01 00:01:00' as timestamp), 2009,1;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union distinct
> 16:01:11.912 select 0,true,0,0,0,0,cast(0 as float),0,'01/01/09','0',cast('2009-01-01 00:00:00' as timestamp),2009,1
> 16:01:11.912 union distinct
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union distinct
> 16:01:11.912 select 1,false,1,1,1,10,cast(1.1 as float),10.1,'01/01/09','1',cast('2009-01-01 00:01:00' as timestamp),2009,1;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2
> 16:01:11.912 union distinct
> 16:01:11.912 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2)
> 16:01:11.912 order by 1 limit 3;
> 16:01:11.912
> 16:01:11.912 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.912 -- executing against localhost:21000
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union distinct
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.912 union all
> 16:01:11.912 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2
> 16:01:11.912 union all
> 16:01:11.912 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2)
> 16:01:11.913 order by 1,2 limit 3;
> 16:01:11.913
> 16:01:11.913 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.913 -- executing against localhost:21000
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union all
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union distinct
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2
> 16:01:11.913 union all
> 16:01:11.913 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2)
> 16:01:11.913 order by 1,2 limit 4;
> 16:01:11.913
> 16:01:11.913 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.913 -- executing against localhost:21000
> 16:01:11.913 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union all
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2)
> 16:01:11.913 union all
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1;
> 16:01:11.913
> 16:01:11.913 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.913 -- executing against localhost:21000
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union all
> 16:01:11.913 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union all
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2);
> 16:01:11.913
> 16:01:11.913 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.913 -- executing against localhost:21000
> 16:01:11.913 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union distinct
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2)
> 16:01:11.913 union distinct
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1;
> 16:01:11.913
> 16:01:11.913 MainThread: TIMESTAMP columns unsupported in avro, skipping verification.
> 16:01:11.913 -- executing against localhost:21000
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union distinct
> 16:01:11.913 (select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=1
> 16:01:11.913 union distinct
> 16:01:11.913 select id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col, timestamp_col, year, month from alltypestiny where year=2009 and month=2);
> 16:01:11.913
> 16:01:11.913 TestQueries.test_analytic_fns[exec_option: {'disable_codegen': True, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:11.913 [gw0] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.913 query_test/test_queries.py:61: in test_analytic_fns
> 16:01:11.913 self.run_test_case('QueryTest/analytic-fns', vector)
> 16:01:11.913 common/impala_test_suite.py:307: in run_test_case
> 16:01:11.913 table_format_info, use_db, pytest.config.option.scale_factor)
> 16:01:11.913 common/impala_test_suite.py:452: in change_database
> 16:01:11.913 impala_client.execute(query)
> 16:01:11.913 common/impala_connection.py:160: in execute
> 16:01:11.913 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.913 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.913 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.913 beeswax/impala_beeswax.py:337: in __execute_query
> 16:01:11.913 handle = self.execute_query_async(query_string, user=user)
> 16:01:11.913 beeswax/impala_beeswax.py:333: in execute_query_async
> 16:01:11.913 return self.__do_rpc(lambda: self.imp_service.query(query,))
> 16:01:11.913 beeswax/impala_beeswax.py:454: in __do_rpc
> 16:01:11.913 raise ImpalaBeeswaxException("Not connected", None)
> 16:01:11.913 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.913 E Not connected
> 16:01:11.914 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.914 -- executing against localhost:21000
> 16:01:11.914 use functional_seq_bzip;
> 16:01:11.914
> 16:01:11.914 TestQueries.test_analytic_fns[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: seq/bzip/block]
> 16:01:11.914 [gw0] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.915 query_test/test_queries.py:61: in test_analytic_fns
> 16:01:11.915 self.run_test_case('QueryTest/analytic-fns', vector)
> 16:01:11.915 common/impala_test_suite.py:307: in run_test_case
> 16:01:11.915 table_format_info, use_db, pytest.config.option.scale_factor)
> 16:01:11.915 common/impala_test_suite.py:452: in change_database
> 16:01:11.915 impala_client.execute(query)
> 16:01:11.915 common/impala_connection.py:160: in execute
> 16:01:11.915 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.915 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.915 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.915 beeswax/impala_beeswax.py:337: in __execute_query
> 16:01:11.915 handle = self.execute_query_async(query_string, user=user)
> 16:01:11.915 beeswax/impala_beeswax.py:333: in execute_query_async
> 16:01:11.915 return self.__do_rpc(lambda: self.imp_service.query(query,))
> 16:01:11.915 beeswax/impala_beeswax.py:454: in __do_rpc
> 16:01:11.915 raise ImpalaBeeswaxException("Not connected", None)
> 16:01:11.915 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.915 E Not connected
> 16:01:11.915 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.915 -- executing against localhost:21000
> 16:01:11.915 use functional_seq_bzip;
> 16:01:11.916
> 16:01:11.916 TestExprs.test_exprs[exec_option: {'disable_codegen': False, 'abort_on_error': 1, 'exec_single_node_rows_threshold': 0, 'batch_size': 0, 'num_nodes': 0} | table_format: text/none | enable_expr_rewrites: 1]
> 16:01:11.916 [gw2] linux2 -- Python 2.6.6 /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.916 query_test/test_exprs.py:58: in test_exprs
> 16:01:11.916 self.run_test_case('QueryTest/exprs', vector)
> 16:01:11.916 common/impala_test_suite.py:307: in run_test_case
> 16:01:11.916 table_format_info, use_db, pytest.config.option.scale_factor)
> 16:01:11.916 common/impala_test_suite.py:452: in change_database
> 16:01:11.916 impala_client.execute(query)
> 16:01:11.916 common/impala_connection.py:160: in execute
> 16:01:11.916 return self.__beeswax_client.execute(sql_stmt, user=user)
> 16:01:11.916 beeswax/impala_beeswax.py:173: in execute
> 16:01:11.916 handle = self.__execute_query(query_string.strip(), user=user)
> 16:01:11.916 beeswax/impala_beeswax.py:337: in __execute_query
> 16:01:11.916 handle = self.execute_query_async(query_string, user=user)
> 16:01:11.916 beeswax/impala_beeswax.py:333: in execute_query_async
> 16:01:11.916 return self.__do_rpc(lambda: self.imp_service.query(query,))
> 16:01:11.916 beeswax/impala_beeswax.py:465: in __do_rpc
> 16:01:11.916 raise ImpalaBeeswaxException(self.__build_error_message(u), u)
> 16:01:11.916 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:11.916 E INNER EXCEPTION: <class 'socket.error'>
> 16:01:11.916 E MESSAGE: [Errno 32] Broken pipe
> 16:01:11.917 ----------------------------- Captured stderr call -----------------------------
> 16:01:11.917 -- executing against localhost:21000
> 16:01:11.917 use functional;
> 16:01:11.917
> 16:01:11.917 !!!!!!!!!!!!!!!!!!! Interrupted: stopping after 10 failures !!!!!!!!!!!!!!!!!!!!
> 16:01:11.918 ===== 10 failed, 7277 passed, 84 skipped, 154 xfailed in 34778.43 seconds ======
> 16:01:11.995 ============================= test session starts ==============================
> 16:01:11.996 platform linux2 -- Python 2.6.6, pytest-2.9.2, py-1.4.32, pluggy-0.3.1 -- /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/bin/../infra/python/env/bin/python
> 16:01:11.997 cachedir: .cache
> 16:01:11.997 rootdir: /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/tests, inifile: pytest.ini
> 16:01:11.998 plugins: random-0.2, xdist-1.15.0
> 16:01:11.998 collecting ... collected 2 items
> 16:01:12.017
> 16:01:12.017 verifiers/test_verify_metrics.py::TestValidateMetrics::test_metrics_are_zero ERROR
> 16:01:12.094 verifiers/test_verify_metrics.py::TestValidateMetrics::test_num_unused_buffers ERROR
> 16:01:12.165
> 16:01:12.165 generated xml file: /data/jenkins/workspace/impala-private-build-and-test/repos/Impala/logs/ee_tests/results/TEST-impala-verify-metrics.xml
> 16:01:12.165 =========================== short test summary info ============================
> 16:01:12.166 ERROR verifiers/test_verify_metrics.py::TestValidateMetrics::()::test_metrics_are_zero
> 16:01:12.166 ERROR verifiers/test_verify_metrics.py::TestValidateMetrics::()::test_num_unused_buffers
> 16:01:12.167 ==================================== ERRORS ====================================
> 16:01:12.167 _________ ERROR at setup of TestValidateMetrics.test_metrics_are_zero __________
> 16:01:12.168 common/impala_test_suite.py:122: in setup_class
> 16:01:12.168 cls.client = cls.create_impala_client(IMPALAD)
> 16:01:12.169 common/impala_test_suite.py:146: in create_impala_client
> 16:01:12.169 client.connect()
> 16:01:12.170 common/impala_connection.py:147: in connect
> 16:01:12.170 self.__beeswax_client.connect()
> 16:01:12.171 beeswax/impala_beeswax.py:148: in connect
> 16:01:12.172 raise ImpalaBeeswaxException(self.__build_error_message(e), e)
> 16:01:12.173 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:12.174 E INNER EXCEPTION: <class 'thrift.transport.TTransport.TTransportException'>
> 16:01:12.175 E MESSAGE: Could not connect to localhost:21000
> 16:01:12.175 ________ ERROR at setup of TestValidateMetrics.test_num_unused_buffers _________
> 16:01:12.175 common/impala_test_suite.py:122: in setup_class
> 16:01:12.176 cls.client = cls.create_impala_client(IMPALAD)
> 16:01:12.176 common/impala_test_suite.py:146: in create_impala_client
> 16:01:12.177 client.connect()
> 16:01:12.177 common/impala_connection.py:147: in connect
> 16:01:12.177 self.__beeswax_client.connect()
> 16:01:12.178 beeswax/impala_beeswax.py:148: in connect
> 16:01:12.179 raise ImpalaBeeswaxException(self.__build_error_message(e), e)
> 16:01:12.180 E ImpalaBeeswaxException: ImpalaBeeswaxException:
> 16:01:12.181 E INNER EXCEPTION: <class 'thrift.transport.TTransport.TTransportException'>
> 16:01:12.182 E MESSAGE: Could not connect to localhost:21000
> 16:01:12.182 =========================== 2 error in 0.19 seconds ============================
> {code}
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-all-unsubscribe@impala.apache.org
For additional commands, e-mail: issues-all-help@impala.apache.org