[ https://issues.apache.org/jira/browse/IMPALA-7013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472386#comment-16472386 ]
Dan Hecht commented on IMPALA-7013: ----------------------------------- cc [~kwho] > test_insert_permutation failed with "timed out waiting for receiver fragment > instance" > -------------------------------------------------------------------------------------- > > Key: IMPALA-7013 > URL: https://issues.apache.org/jira/browse/IMPALA-7013 > Project: IMPALA > Issue Type: Bug > Components: Distributed Exec > Affects Versions: Impala 2.13.0 > Reporter: Tim Armstrong > Assignee: Joe McDonnell > Priority: Critical > Labels: flaky > > This is a weird failure that I don't quite understand > {noformat} > 11:32:57 > TestInsertQueriesWithPermutation.test_insert_permutation[exec_option: > {'batch_size': 0, 'num_nodes': 0, 'disable_codegen_rows_threshold': 0, > 'disable_codegen': False, 'abort_on_error': 1, 'debug_action': None, > 'exec_single_node_rows_threshold': 0} | table_format: text/none] > 11:32:57 [gw2] linux2 -- Python 2.6.6 > /data/jenkins/workspace/impala-cdh5-trunk-core-s3/repos/Impala/bin/../infra/python/env/bin/python > 11:32:57 query_test/test_insert_permutation.py:50: in test_insert_permutation > 11:32:57 self.run_test_case('QueryTest/insert_permutation', vector) > 11:32:57 common/impala_test_suite.py:405: in run_test_case > 11:32:57 result = self.__execute_query(target_impalad_client, query, > user=user) > 11:32:57 common/impala_test_suite.py:620: in __execute_query > 11:32:57 return impalad_client.execute(query, user=user) > 11:32:57 common/impala_connection.py:160: in execute > 11:32:57 return self.__beeswax_client.execute(sql_stmt, user=user) > 11:32:57 beeswax/impala_beeswax.py:173: in execute > 11:32:57 handle = self.__execute_query(query_string.strip(), user=user) > 11:32:57 beeswax/impala_beeswax.py:341: in __execute_query > 11:32:57 self.wait_for_completion(handle) > 11:32:57 beeswax/impala_beeswax.py:361: in wait_for_completion > 11:32:57 raise ImpalaBeeswaxException("Query aborted:" + error_log, None) > 11:32:57 E ImpalaBeeswaxException: ImpalaBeeswaxException: > 11:32:57 E Query aborted:Sender 127.0.0.1 timed out waiting for receiver > fragment instance: 994ce8cbd8cb4eb2:f1cb807c00000000, dest node: 1 > 11:32:57 ---------------------------- Captured stderr setup > ----------------------------- > 11:32:57 -- connecting to: localhost:21000 > 11:32:57 ----------------------------- Captured stderr call > ----------------------------- > 11:32:57 -- executing against localhost:21000 > 11:32:57 use default; > 11:32:57 > 11:32:57 SET sync_ddl=1; > 11:32:57 -- executing against localhost:21000 > 11:32:57 drop database if exists `insert_permutation_test` cascade; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 use functional; > 11:32:57 > 11:32:57 SET batch_size=0; > 11:32:57 SET num_nodes=0; > 11:32:57 SET disable_codegen_rows_threshold=0; > 11:32:57 SET disable_codegen=False; > 11:32:57 SET abort_on_error=1; > 11:32:57 SET exec_single_node_rows_threshold=0; > 11:32:57 -- executing against localhost:21000 > 11:32:57 create database insert_permutation_test location > 11:32:57 's3a://impala-cdh5-s3-test/test-warehouse/insert_permutation_test'; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 use insert_permutation_test; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 create table perm_nopart(int_col1 int, string_col string, int_col2 > int); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 > 11:32:57 create table perm_part(int_col1 int, string_col string) partitioned > by (p1 int, p2 string); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 > 11:32:57 create table parquet_part(int_col1 int, string_col string) > 11:32:57 partitioned by (p1 int, p2 string) stored as parquet; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_nopart(int_col1, string_col, int_col2) > values(1,'str',2); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_nopart(int_col2, string_col, int_col1) > values(1,'str',2); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_nopart(int_col2) values(1); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part(p1, string_col, int_col1, p2) > values(10,'str',1, 'hello'); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part(p2, string_col, int_col1, p1) > values('hello','str',1, 10); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part(p2, p1) values('hello', 10); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part(p2) PARTITION(p1=10) values('hello'); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part(int_col1, string_col) PARTITION(p1=10, p2) > values(1,'perm_col','part_col'); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part() PARTITION(p1=10, p2='foo'); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_part() PARTITION(p1, p2='foo') values(5); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_part; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 invalidate metadata insert_permutation_test.perm_nopart; > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 insert into perm_nopart(); > 11:32:57 > 11:32:57 -- executing against localhost:21000 > 11:32:57 select * from perm_nopart; > {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-all-unsubscr...@impala.apache.org For additional commands, e-mail: issues-all-h...@impala.apache.org