Csaba Ringhofer created IMPALA-13037:
----------------------------------------
Summary: EventsProcessorStressTest can hang
Key: IMPALA-13037
URL: https://issues.apache.org/jira/browse/IMPALA-13037
Project: IMPALA
Issue Type: Bug
Components: Catalog, Infrastructure
Reporter: Csaba Ringhofer
The test failed with timeout.
>From mvn.log the last line is:
20:17:53 [INFO] Running
org.apache.impala.catalog.events.EventsProcessorStressTest
Things seem to be hanging from 2024.04.22 20:17:53 to 2024.04.23
The tests seems to wait for a Hive query.
>From FeSupport.INFO:
{code}
I0422 20:17:55.478875 7949 RandomHiveQueryRunner.java:1102] Client 0 running
hive query set 2:
insert into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
create database if not exists events_stress_db_0
drop table if exists events_stress_db_0.stress_test_tbl_0_alltypes_part
create table if not exists
events_stress_db_0.stress_test_tbl_0_alltypes_part like functional.alltypes
set hive.exec.dynamic.partition.mode = nonstrict
set hive.exec.max.dynamic.partitions = 10000
set hive.exec.max.dynamic.partitions.pernode = 10000
set tez.session.am.dag.submit.timeout.secs = 2
I0422 20:17:55.478940 7949 HiveJdbcClientPool.java:102] Executing sql : create
database if not exists events_stress_db_0
I0422 20:17:55.493497 7768 MetastoreShim.java:843] EventId: 33414 EventType:
COMMIT_TXN transaction id: 2075
I0422 20:17:55.493682 7768 MetastoreEvents.java:302] Total number of events
received: 6 Total number of events filtered out: 0
I0422 20:17:55.494762 7768 MetastoreEvents.java:825] EventId: 33407 EventType:
CREATE_DATABASE Successfully added database events_stress_db_0
I0422 20:17:55.508478 7949 HiveJdbcClientPool.java:102] Executing sql : drop
table if exists events_stress_db_0.stress_test_tbl_0_alltypes_part
I0422 20:17:55.516858 7768 MetastoreEvents.java:825] EventId: 33410 EventType:
CREATE_TABLE Successfully added table events_stress_db_0.stress_test_tbl_0_part
I0422 20:17:55.518288 7768 CatalogOpExecutor.java:4713] EventId: 33413 Table
events_stress_db_0.stress_test_tbl_0_part is not loaded. Skipping add partitions
I0422 20:17:55.519479 7768 MetastoreEventsProcessor.java:1340] Time elapsed in
processing event batch: 178.895ms
I0422 20:17:55.521183 7768 MetastoreEventsProcessor.java:1120] Latest event in
HMS: id=33420, time=1713842275. Last synced event: id=33414, time=1713842275.
I0422 20:17:55.533375 7949 HiveJdbcClientPool.java:102] Executing sql : create
table if not exists events_stress_db_0.stress_test_tbl_0_alltypes_part like
functional.alltypes
I0422 20:17:55.611153 7949 HiveJdbcClientPool.java:102] Executing sql : set
hive.exec.dynamic.partition.mode = nonstrict
I0422 20:17:55.616571 7949 HiveJdbcClientPool.java:102] Executing sql : set
hive.exec.max.dynamic.partitions = 10000
I0422 20:17:55.619197 7949 HiveJdbcClientPool.java:102] Executing sql : set
hive.exec.max.dynamic.partitions.pernode = 10000
I0422 20:17:55.621069 7949 HiveJdbcClientPool.java:102] Executing sql : set
tez.session.am.dag.submit.timeout.secs = 2
I0422 20:17:55.622972 7949 HiveJdbcClientPool.java:102] Executing sql : insert
into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
I0422 20:17:57.163591 7950 CatalogServiceCatalog.java:2747] Refreshing table
metadata: events_stress_db_0.stress_test_tbl_0_part
I0422 20:17:57.829802 7768 MetastoreEventsProcessor.java:982] Received 6
events. First event id: 33416.
I0422 20:17:57.833026 7768 MetastoreShim.java:843] EventId: 33417 EventType:
COMMIT_TXN transaction id: 2076
I0422 20:17:57.833222 7768 MetastoreShim.java:843] EventId: 33419 EventType:
COMMIT_TXN transaction id: 2077
I0422 20:17:57.833334 7768 MetastoreShim.java:843] EventId: 33421 EventType:
COMMIT_TXN transaction id: 2078
I0422 20:17:57.834242 7768 MetastoreShim.java:843] EventId: 33424 EventType:
COMMIT_TXN transaction id: 2079
I0422 20:17:57.834323 7768 MetastoreEvents.java:302] Total number of events
received: 6 Total number of events filtered out: 0
I0422 20:17:57.834570 7768 CatalogOpExecutor.java:4862] EventId: 33416 Table
events_stress_db_0.stress_test_tbl_0_part is not loaded. Not processing the
event.
I0422 20:17:57.837756 7768 MetastoreEvents.java:825] EventId: 33423 EventType:
CREATE_TABLE Successfully added table
events_stress_db_0.stress_test_tbl_0_alltypes_part
I0422 20:17:57.838668 7768 MetastoreEventsProcessor.java:1340] Time elapsed in
processing event batch: 8.625ms
I0422 20:17:57.840027 7768 MetastoreEventsProcessor.java:1120] Latest event in
HMS: id=33425, time=1713842275. Last synced event: id=33424, time=1713842275.
I0422 20:18:03.143219 7768 MetastoreEventsProcessor.java:982] Received 0
events. First event id: none.
E0423 15:48:25.625319 7949 RandomHiveQueryRunner.java:152] Unexpected error
received while running the hive query
Java exception follows:
java.sql.SQLException: org.apache.thrift.transport.TTransportException: Socket
is closed by peer.
at
org.apache.hive.jdbc.HiveStatement.waitForOperationToComplete(HiveStatement.java:463)
at org.apache.hive.jdbc.HiveStatement.execute(HiveStatement.java:314)
at
org.apache.impala.testutil.HiveJdbcClientPool$HiveJdbcClient.executeSql(HiveJdbcClientPool.java:103)
at
org.apache.impala.util.RandomHiveQueryRunner$TestHiveQuery.runInternal(RandomHiveQueryRunner.java:141)
at
org.apache.impala.util.RandomHiveQueryRunner$TestHiveQuery.run(RandomHiveQueryRunner.java:150)
at
org.apache.impala.util.RandomHiveQueryRunner.lambda$start$0(RandomHiveQueryRunner.java:1104)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Suppressed: java.sql.SQLException:
org.apache.thrift.transport.TTransportException: Socket is closed by peer.
at
org.apache.hive.jdbc.HiveStatement.closeStatementIfNeeded(HiveStatement.java:225)
at
org.apache.hive.jdbc.HiveStatement.closeClientOperation(HiveStatement.java:266)
at
org.apache.hive.jdbc.HiveStatement.close(HiveStatement.java:289)
at
org.apache.impala.testutil.HiveJdbcClientPool$HiveJdbcClient.close(HiveJdbcClientPool.java:71)
at
org.apache.impala.util.RandomHiveQueryRunner$TestHiveQuery.run(RandomHiveQueryRunner.java:151)
... 5 more
Caused by: org.apache.thrift.transport.TTransportException: Socket is
closed by peer.
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:184)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.transport.TSaslTransport.readLength(TSaslTransport.java:338)
at
org.apache.thrift.transport.TSaslTransport.readFrame(TSaslTransport.java:421)
at
org.apache.thrift.transport.TSaslTransport.read(TSaslTransport.java:397)
at
org.apache.thrift.transport.TSaslClientTransport.read(TSaslClientTransport.java:39)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:464)
at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:362)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:245)
at
org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.recv_CloseOperation(TCLIService.java:494)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.CloseOperation(TCLIService.java:481)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hive.jdbc.HiveConnection$SynchronizedHandler.invoke(HiveConnection.java:2129)
at com.sun.proxy.$Proxy47.CloseOperation(Unknown Source)
at
org.apache.hive.jdbc.HiveStatement.closeStatementIfNeeded(HiveStatement.java:216)
... 9 more
Caused by: org.apache.thrift.transport.TTransportException: Socket is closed by
peer.
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:184)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.transport.TSaslTransport.readLength(TSaslTransport.java:338)
at
org.apache.thrift.transport.TSaslTransport.readFrame(TSaslTransport.java:421)
at
org.apache.thrift.transport.TSaslTransport.read(TSaslTransport.java:397)
at
org.apache.thrift.transport.TSaslClientTransport.read(TSaslClientTransport.java:39)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:464)
at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:362)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:245)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.recv_GetOperationStatus(TCLIService.java:448)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.GetOperationStatus(TCLIService.java:435)
at sun.reflect.GeneratedMethodAccessor39.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hive.jdbc.HiveConnection$SynchronizedHandler.invoke(HiveConnection.java:2129)
at com.sun.proxy.$Proxy47.GetOperationStatus(Unknown Source)
at
org.apache.hive.jdbc.HiveStatement.waitForOperationToComplete(HiveStatement.java:426)
... 9 more
E0423 15:48:26.007812 7768 EventsProcessorStressTest.java:218]
java.util.concurrent.ExecutionException: Client 0 errored out while executing
query set 2
insert into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
create database if not exists events_stress_db_0
drop table if exists events_stress_db_0.stress_test_tbl_0_alltypes_part
create table if not exists
events_stress_db_0.stress_test_tbl_0_alltypes_part like functional.alltypes
set hive.exec.dynamic.partition.mode = nonstrict
set hive.exec.max.dynamic.partitions = 10000
set hive.exec.max.dynamic.partitions.pernode = 10000
set tez.session.am.dag.submit.timeout.secs = 2 or its dependent queries.
Exception message is: org.apache.thrift.transport.TTransportException: Socket
is closed by peer.
Java exception follows:
java.util.concurrent.ExecutionException:
java.util.concurrent.ExecutionException: Client 0 errored out while executing
query set 2
insert into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
create database if not exists events_stress_db_0
drop table if exists events_stress_db_0.stress_test_tbl_0_alltypes_part
create table if not exists
events_stress_db_0.stress_test_tbl_0_alltypes_part like functional.alltypes
set hive.exec.dynamic.partition.mode = nonstrict
set hive.exec.max.dynamic.partitions = 10000
set hive.exec.max.dynamic.partitions.pernode = 10000
set tez.session.am.dag.submit.timeout.secs = 2 or its dependent queries.
Exception message is: org.apache.thrift.transport.TTransportException: Socket
is closed by peer.
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at
org.apache.impala.util.RandomHiveQueryRunner.checkForErrors(RandomHiveQueryRunner.java:1130)
at
org.apache.impala.catalog.events.EventsProcessorStressTest.testUsingRandomHiveQueries(EventsProcessorStressTest.java:216)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:316)
at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:240)
at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:214)
at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:155)
at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:385)
at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
at
org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:507)
at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:495)
Caused by: java.util.concurrent.ExecutionException: Client 0 errored out while
executing query set 2
insert into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
create database if not exists events_stress_db_0
drop table if exists events_stress_db_0.stress_test_tbl_0_alltypes_part
create table if not exists
events_stress_db_0.stress_test_tbl_0_alltypes_part like functional.alltypes
set hive.exec.dynamic.partition.mode = nonstrict
set hive.exec.max.dynamic.partitions = 10000
set hive.exec.max.dynamic.partitions.pernode = 10000
set tez.session.am.dag.submit.timeout.secs = 2 or its dependent queries.
Exception message is: org.apache.thrift.transport.TTransportException: Socket
is closed by peer.
at
org.apache.impala.util.RandomHiveQueryRunner.lambda$start$0(RandomHiveQueryRunner.java:1107)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.sql.SQLException:
org.apache.thrift.transport.TTransportException: Socket is closed by peer.
at
org.apache.hive.jdbc.HiveStatement.waitForOperationToComplete(HiveStatement.java:463)
at org.apache.hive.jdbc.HiveStatement.execute(HiveStatement.java:314)
at
org.apache.impala.testutil.HiveJdbcClientPool$HiveJdbcClient.executeSql(HiveJdbcClientPool.java:103)
at
org.apache.impala.util.RandomHiveQueryRunner$TestHiveQuery.runInternal(RandomHiveQueryRunner.java:141)
at
org.apache.impala.util.RandomHiveQueryRunner$TestHiveQuery.run(RandomHiveQueryRunner.java:150)
at
org.apache.impala.util.RandomHiveQueryRunner.lambda$start$0(RandomHiveQueryRunner.java:1104)
... 4 more
Suppressed: java.sql.SQLException:
org.apache.thrift.transport.TTransportException: Socket is closed by peer.
at
org.apache.hive.jdbc.HiveStatement.closeStatementIfNeeded(HiveStatement.java:225)
at
org.apache.hive.jdbc.HiveStatement.closeClientOperation(HiveStatement.java:266)
at
org.apache.hive.jdbc.HiveStatement.close(HiveStatement.java:289)
at
org.apache.impala.testutil.HiveJdbcClientPool$HiveJdbcClient.close(HiveJdbcClientPool.java:71)
at
org.apache.impala.util.RandomHiveQueryRunner$TestHiveQuery.run(RandomHiveQueryRunner.java:151)
... 5 more
Caused by: org.apache.thrift.transport.TTransportException: Socket is
closed by peer.
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:184)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.transport.TSaslTransport.readLength(TSaslTransport.java:338)
at
org.apache.thrift.transport.TSaslTransport.readFrame(TSaslTransport.java:421)
at
org.apache.thrift.transport.TSaslTransport.read(TSaslTransport.java:397)
at
org.apache.thrift.transport.TSaslClientTransport.read(TSaslClientTransport.java:39)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:464)
at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:362)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:245)
at
org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.recv_CloseOperation(TCLIService.java:494)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.CloseOperation(TCLIService.java:481)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hive.jdbc.HiveConnection$SynchronizedHandler.invoke(HiveConnection.java:2129)
at com.sun.proxy.$Proxy47.CloseOperation(Unknown Source)
at
org.apache.hive.jdbc.HiveStatement.closeStatementIfNeeded(HiveStatement.java:216)
... 9 more
Caused by: org.apache.thrift.transport.TTransportException: Socket is closed by
peer.
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:184)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.transport.TSaslTransport.readLength(TSaslTransport.java:338)
at
org.apache.thrift.transport.TSaslTransport.readFrame(TSaslTransport.java:421)
at
org.apache.thrift.transport.TSaslTransport.read(TSaslTransport.java:397)
at
org.apache.thrift.transport.TSaslClientTransport.read(TSaslClientTransport.java:39)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:464)
at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:362)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:245)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.recv_GetOperationStatus(TCLIService.java:448)
at
org.apache.hive.service.rpc.thrift.TCLIService$Client.GetOperationStatus(TCLIService.java:435)
at sun.reflect.GeneratedMethodAccessor39.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hive.jdbc.HiveConnection$SynchronizedHandler.invoke(HiveConnection.java:2129)
at com.sun.proxy.$Proxy47.GetOperationStatus(Unknown Source)
at
org.apache.hive.jdbc.HiveStatement.waitForOperationToComplete(HiveStatement.java:426)
... 9 more
{code}
>From hive-server2.log grepping for
>jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df:
{code}
2024-04-22T20:17:55,624 INFO [26e2776e-b6e1-4613-bc70-7a09f8adc770
HiveServer2-Handler-Pool: Thread-121] operation.Operation:
[opType=EXECUTE_STATEMENT,
queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df,
startTime=1713842275623, sessionId=26e2776e-b6e1-4613-bc70-7a09f8adc770,
createTime=1713842273710, userName=anonymous, ipAddress=127.0.0.1]
2024-04-22T20:17:55,625 INFO [26e2776e-b6e1-4613-bc70-7a09f8adc770
HiveServer2-Handler-Pool: Thread-121] ql.Driver: Compiling
command(queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df):
insert into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
2024-04-22T20:17:55,631 INFO [26e2776e-b6e1-4613-bc70-7a09f8adc770
HiveServer2-Handler-Pool: Thread-121] ql.QueryState: Query-level HMS cache
created for jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df
2024-04-22T20:17:56,284 INFO [26e2776e-b6e1-4613-bc70-7a09f8adc770
HiveServer2-Handler-Pool: Thread-121] ql.Driver: Completed compiling
command(queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df);
Time taken: 0.659 seconds
2024-04-22T20:17:56,286 INFO [HiveServer2-Background-Pool: Thread-159]
lockmgr.DbTxnManager: Setting lock request transaction to txnid:2080 for
queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df
2024-04-22T20:17:56,286 INFO [HiveServer2-Background-Pool: Thread-159]
lockmgr.DbLockManager: Requesting lock for
queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df
2024-04-22T20:17:56,292 INFO [HiveServer2-Background-Pool: Thread-159]
lockmgr.DbLockManager: Response to
queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df
LockResponse(lockid:389, state:ACQUIRED)
2024-04-22T20:17:56,293 INFO [HiveServer2-Background-Pool: Thread-159]
ql.Driver: Executing
command(queryId=jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df):
insert into table events_stress_db_0.stress_test_tbl_0_alltypes_part partition
(year,month) select * from functional.alltypes limit 100
2024-04-22T20:17:56,293 INFO [HiveServer2-Background-Pool: Thread-159]
ql.Driver: Query ID =
jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df
2024-04-22T20:17:56,360 INFO [HiveServer2-Background-Pool: Thread-159]
tez.TezTask: Subscribed to counters: [] for queryId:
jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df
{code}
There are no more mentions of the query after this.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
