[IMPALA-13037] EventsProcessorStressTest can hang - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Open
Priority: Critical
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: None
Component/s: Catalog, Infrastructure
Labels:
None

Epic Color:
ghx-label-2

Description

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:

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

From hive-server2.log grepping for jenkins_20240422201755_96876acb-ee10-409e-a6da-bd1a9b4bc6df:

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

There are no more mentions of the query after this.

Attachments

Activity

People

Assignee:: Unassigned

Reporter:: Csaba Ringhofer

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 24/Apr/24 14:26

Updated:: 25/Apr/24 01:33