[ 
https://issues.apache.org/jira/browse/IMPALA-14270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18011185#comment-18011185
 ] 

Surya Hebbar commented on IMPALA-14270:
---------------------------------------

Assigning to [~daniel.becker] based on IMPALA-14066, please feel free to 
reassign.
https://issues.apache.org/jira/browse/IMPALA-14066

> TestDdlStatements.test_create_kudu and 
> TestKuduHMSIntegration.test_create_managed_kudu_tables failing due to 
> unexpected assertion error
> ---------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: IMPALA-14270
>                 URL: https://issues.apache.org/jira/browse/IMPALA-14270
>             Project: IMPALA
>          Issue Type: Bug
>            Reporter: Surya Hebbar
>            Assignee: Daniel Becker
>            Priority: Major
>
> The same error occurs for both
>  * TestDdlStatements.test_create_kudu
>  * TestKuduHMSIntegration.test_create_managed_kudu_tables
> [https://master-03.jenkins.cloudera.com/job/impala-asf-master-core-erasure-coding/496/testReport/]
> [https://master-03.jenkins.cloudera.com/job/impala-asf-master-core-admissiond/113/testReport/]
>  
> *Error Message*
> {code:java}
> /data/jenkins/workspace/impala-asf-master-core-admissiond/repos/Impala/tests/metadata/test_ddl.py:346:
>  in test_create_kudu     multiple_impalad=self._use_multiple_impalad(vector)) 
> common/impala_test_suite.py:889: in run_test_case     
> self.__verify_exceptions(test_section['CATCH'], str(e), use_db) 
> common/impala_test_suite.py:718: in __verify_exceptions     (expected_str, 
> actual_str) E   AssertionError: Unexpected exception string. Expected: 
> Couldn't resolve this master's address bogus.host.name:7051 E   Not found in 
> actual: Query 644a224bf574097c:1a24a2ce00000000 failed:AnalysisException: 
> Cannot analyze Kudu table 'tdata_non_existing_host': Error determining if 
> Kudu's integration with the Hive Metastore is enabled: cannot complete before 
> timeout: KuduRpc(method=getHiveMetastoreConfig, tablet=null, attempt=87, 
> TimeoutTracker(timeout=180000, elapsed=178564), Trace Summary(175296 ms): 
> Sent(0), Received(0), Delayed(86), MasterRefresh(0), AuthRefresh(0), 
> Truncated: false Delayed: (UNKNOWN, [ getHiveMetastoreConfig, 86 ])){code}
>  
> h3. Stacktrace
>  
> {code:java}
> /data/jenkins/workspace/impala-asf-master-core-admissiond/repos/Impala/tests/metadata/test_ddl.py:346:
>  in test_create_kudu
>     multiple_impalad=self._use_multiple_impalad(vector))
> common/impala_test_suite.py:889: in run_test_case
>     self.__verify_exceptions(test_section['CATCH'], str(e), use_db)
> common/impala_test_suite.py:718: in __verify_exceptions
>     (expected_str, actual_str)
> E   AssertionError: Unexpected exception string. Expected: Couldn't resolve 
> this master's address bogus.host.name:7051
> E   Not found in actual: Query 644a224bf574097c:1a24a2ce00000000 
> failed:AnalysisException: Cannot analyze Kudu table 
> 'tdata_non_existing_host': Error determining if Kudu's integration with the 
> Hive Metastore is enabled: cannot complete before timeout: 
> KuduRpc(method=getHiveMetastoreConfig, tablet=null, attempt=87, 
> TimeoutTracker(timeout=180000, elapsed=178564), Trace Summary(175296 ms): 
> Sent(0), Received(0), Delayed(86), MasterRefresh(0), AuthRefresh(0), 
> Truncated: false Delayed: (UNKNOWN, [ getHiveMetastoreConfig, 86 ])){code}
>  
> h3. Standard Error
>  
> {code:java}
> -- 2025-07-26 12:30:00,755 INFO     MainThread: beeswax: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:00,755 INFO     MainThread: hs2: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:00,755 INFO     MainThread: hs2-http: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:00,755 INFO     MainThread: hs2: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:00,755 INFO     MainThread: Could not connect to ('::1', 
> 21050, 0, 0)
> Traceback (most recent call last):
>   File 
> "/data/jenkins/workspace/impala-asf-master-core-admissiond/repos/Impala/infra/python/env-gcc10.4.0/lib/python2.7/site-packages/thrift/transport/TSocket.py",
>  line 137, in open
>     handle.connect(sockaddr)
>   File 
> "/data/jenkins/workspace/impala-asf-master-core-admissiond/Impala-Toolchain/toolchain-packages-gcc10.4.0/python-2.7.16/lib/python2.7/socket.py",
>  line 228, in meth
>     return getattr(self._sock,name)(*args)
> error: [Errno 111] Connection refused
> -- 2025-07-26 12:30:00,755 INFO     MainThread: hs2: connected to 
> localhost:21050 with impyla hs2
> -- 2025-07-26 12:30:00,755 INFO     MainThread: hs2: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:00,755 INFO     MainThread: hs2: set_configuration:
> set sync_ddl=True;
> -- 2025-07-26 12:30:00,756 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: d24292041f03bfc7:9ab164950c196ba2 main_cursor: 
> True user: None
> DROP DATABASE IF EXISTS `test_create_kudu_d5afa907` CASCADE;
> -- 2025-07-26 12:30:06,473 INFO     MainThread: 
> d649e1317e6566d5:7c06029100000000: query started
> -- 2025-07-26 12:30:06,473 INFO     MainThread: 
> d649e1317e6566d5:7c06029100000000: getting log for operation
> -- 2025-07-26 12:30:06,473 INFO     MainThread: 
> d649e1317e6566d5:7c06029100000000: getting runtime profile operation
> -- 2025-07-26 12:30:06,474 INFO     MainThread: 
> d649e1317e6566d5:7c06029100000000: closing query for operation
> -- 2025-07-26 12:30:06,477 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: d24292041f03bfc7:9ab164950c196ba2 main_cursor: 
> True user: None
> CREATE DATABASE `test_create_kudu_d5afa907`;
> -- 2025-07-26 12:30:12,487 INFO     MainThread: 
> 1f496975b015f838:704034b500000000: query started
> -- 2025-07-26 12:30:12,488 INFO     MainThread: 
> 1f496975b015f838:704034b500000000: getting log for operation
> -- 2025-07-26 12:30:12,488 INFO     MainThread: 
> 1f496975b015f838:704034b500000000: getting runtime profile operation
> -- 2025-07-26 12:30:12,488 INFO     MainThread: 
> 1f496975b015f838:704034b500000000: closing query for operation
> -- 2025-07-26 12:30:12,488 INFO     MainThread: Created database 
> "test_create_kudu_d5afa907" for test ID 
> "metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol: hs2 
> | table_format: text/none | exec_option: {'disable_codegen_rows_threshold': 
> 0, 'test_replan': 1, 'batch_size': 0, 'num_nodes': 0, 'sync_ddl': 0, 
> 'disable_codegen': False, 'abort_on_error': 1, 
> 'exec_single_node_rows_threshold': 0}-unique_database0]"
> -- 2025-07-26 12:30:12,488 INFO     MainThread: hs2: closing 1 sync and 0 
> async hs2 connections to: localhost:21050
> -- 2025-07-26 12:30:12,490 INFO     MainThread: hs2: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:12,490 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> use test_create_kudu_d5afa907;
> -- 2025-07-26 12:30:12,492 INFO     MainThread: 
> 7744e136a535c4fd:8d2f28eb00000000: query started
> -- 2025-07-26 12:30:12,492 INFO     MainThread: 
> 7744e136a535c4fd:8d2f28eb00000000: getting log for operation
> -- 2025-07-26 12:30:12,492 INFO     MainThread: 
> 7744e136a535c4fd:8d2f28eb00000000: getting runtime profile operation
> -- 2025-07-26 12:30:12,493 INFO     MainThread: 
> 7744e136a535c4fd:8d2f28eb00000000: closing query for operation
> -- 2025-07-26 12:30:12,493 INFO     MainThread: hs2: 
> set 
> client_identifier=metadata/test_ddl.py::TestDdlStatements::()::test_create_kudu[protocol:hs2|table_format:text/none|exec_option:{'disable_codegen_rows_threshold':0;'test_replan':1;'batch_size':0;'num_nodes':0;'sync_ddl':0;'disable_codegen':False;'abort_on_error':1;'exec_si;
> -- 2025-07-26 12:30:12,493 INFO     MainThread: hs2: set_configuration:
> set disable_codegen_rows_threshold=0;
> set test_replan=1;
> set kudu_read_mode=READ_AT_SNAPSHOT;
> set batch_size=0;
> set num_nodes=0;
> set sync_ddl=0;
> set disable_codegen=False;
> set abort_on_error=False;
> set exec_single_node_rows_threshold=0;
> -- 2025-07-26 12:30:12,493 INFO     MainThread: Loading query test file: 
> /data/jenkins/workspace/impala-asf-master-core-admissiond/repos/Impala/testdata/workloads/functional-query/queries/QueryTest/kudu_create.test
> -- 2025-07-26 12:30:14,441 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table t primary key (id) partition by hash (id) partitions 3
> stored as kudu
> as select id, int_col from functional.alltypestiny;
> -- 2025-07-26 12:30:16,467 INFO     MainThread: 
> 4642e617c686a4be:6e0de99800000000: query started
> -- 2025-07-26 12:30:16,468 INFO     MainThread: 
> 4642e617c686a4be:6e0de99800000000: getting log for operation
> -- 2025-07-26 12:30:16,468 INFO     MainThread: 
> 4642e617c686a4be:6e0de99800000000: getting runtime profile operation
> -- 2025-07-26 12:30:16,471 INFO     MainThread: 
> 4642e617c686a4be:6e0de99800000000: closing query for operation
> -- 2025-07-26 12:30:16,471 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> select * from t;
> -- 2025-07-26 12:30:20,508 INFO     MainThread: 
> 944791b109b449d2:e867c7c800000000: query started
> -- 2025-07-26 12:30:20,511 INFO     MainThread: 
> 944791b109b449d2:e867c7c800000000: getting log for operation
> -- 2025-07-26 12:30:20,511 INFO     MainThread: 
> 944791b109b449d2:e867c7c800000000: getting runtime profile operation
> -- 2025-07-26 12:30:20,513 INFO     MainThread: 
> 944791b109b449d2:e867c7c800000000: closing query for operation
> -- 2025-07-26 12:30:20,514 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (x int, y boolean, primary key(x, y))
>   partition by hash (x) partitions 3 stored as kudu;
> -- 2025-07-26 12:30:20,558 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (x int, y float, primary key(x, y))
>   partition by hash (x) partitions 3 stored as kudu;
> -- 2025-07-26 12:30:20,592 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (x int, y int, primary key(y))
>   partition by hash (y) partitions 3 stored as kudu;
> -- 2025-07-26 12:30:20,625 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (x int, y int, z int, primary key(y,x))
>   partition by hash (y) partitions 3 stored as kudu;
> -- 2025-07-26 12:30:20,668 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (a int, b int, c int, d int, primary key(a, b, c))
>   partition by hash(a,b) partitions 8, hash(c) partitions 1 stored as kudu;
> -- 2025-07-26 12:30:20,702 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (a int, b int, primary key (a))
>   partition by hash (a) partitions 3, hash (a) partitions 2 stored as kudu;
> -- 2025-07-26 12:30:20,734 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (a int primary key) partition by hash (a, a, a) partitions 3
> stored as kudu;
> -- 2025-07-26 12:30:20,767 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table `add`(`analytic` int, `function` int, primary key(`analytic`, 
> `function`))
> partition by hash (`analytic`) partitions 4, range (`function`)
> (partition values <= 1, partition 1 < values <= 10, partition 10 < values) 
> stored as kudu;
> -- 2025-07-26 12:30:22,674 INFO     MainThread: 
> 114e535f47c8c569:f2e2477000000000: query started
> -- 2025-07-26 12:30:22,674 INFO     MainThread: 
> 114e535f47c8c569:f2e2477000000000: getting log for operation
> -- 2025-07-26 12:30:22,674 INFO     MainThread: 
> 114e535f47c8c569:f2e2477000000000: getting runtime profile operation
> -- 2025-07-26 12:30:22,675 INFO     MainThread: 
> 114e535f47c8c569:f2e2477000000000: closing query for operation
> -- 2025-07-26 12:30:22,675 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> insert into `add` select id, int_col from functional.alltypestiny;
> -- 2025-07-26 12:30:26,734 INFO     MainThread: 
> 914c0721b0c5a505:c68c9be400000000: query started
> -- 2025-07-26 12:30:26,734 INFO     MainThread: 
> 914c0721b0c5a505:c68c9be400000000: getting log for operation
> -- 2025-07-26 12:30:26,735 INFO     MainThread: 
> 914c0721b0c5a505:c68c9be400000000: getting runtime profile operation
> -- 2025-07-26 12:30:26,737 INFO     MainThread: 
> 914c0721b0c5a505:c68c9be400000000: closing query for operation
> -- 2025-07-26 12:30:26,737 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> select * from `add`;
> -- 2025-07-26 12:30:26,774 INFO     MainThread: 
> 6b40cc2ce5d4f9ad:36d9175000000000: query started
> -- 2025-07-26 12:30:26,775 INFO     MainThread: 
> 6b40cc2ce5d4f9ad:36d9175000000000: getting log for operation
> -- 2025-07-26 12:30:26,776 INFO     MainThread: 
> 6b40cc2ce5d4f9ad:36d9175000000000: getting runtime profile operation
> -- 2025-07-26 12:30:26,777 INFO     MainThread: 
> 6b40cc2ce5d4f9ad:36d9175000000000: closing query for operation
> -- 2025-07-26 12:30:26,778 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tab (a int not null primary key)
> partition by range (a) (partition value = false)
> stored as kudu;
> -- 2025-07-26 12:30:27,583 INFO     MainThread: 
> 184e4a27b854c011:41cd1c2500000000: query started
> -- 2025-07-26 12:30:27,584 INFO     MainThread: 
> 184e4a27b854c011:41cd1c2500000000: getting log for operation
> -- 2025-07-26 12:30:27,584 INFO     MainThread: 
> 184e4a27b854c011:41cd1c2500000000: getting runtime profile operation
> -- 2025-07-26 12:30:27,584 INFO     MainThread: 
> 184e4a27b854c011:41cd1c2500000000: closing query for operation
> -- 2025-07-26 12:30:27,585 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tdata_bogus_host (id int primary key, name string, valf float, 
> vali bigint)
>   PARTITION BY RANGE (PARTITION 10 <= VALUES <= 30) STORED AS KUDU
>   TBLPROPERTIES('kudu.master_addresses' = 'bogus host name');
> -- 2025-07-26 12:30:27,625 INFO     MainThread: hs2: executing against Impala 
> at localhost:21050. session: 7045df2918dade5c:c4a41e3170cb6a99 main_cursor: 
> True user: None
> create table tdata_non_existing_host
> (id int primary key, name string, valf float, vali bigint)
>   PARTITION BY RANGE (PARTITION 10 <= VALUES <= 30) STORED AS KUDU
>   TBLPROPERTIES('kudu.master_addresses' = 'bogus.host.name');{code}
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to