HonestManXin opened a new pull request, #60013:
URL: https://github.com/apache/doris/pull/60013
newSessionVariable just read field of defaultSessionVariable and won't
change it, so use read lock to reduce lock contention
```
"thrift-server-pool-47" #534 daemon prio=5 os_prio=0 cpu=3837.23ms
elapsed=895.28s tid=0x00007ebbc002fcf0 nid=0x3244aa waiting on condition
[0x00007eb705ad9000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x00007ec62e946238> (a
java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at
java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:211)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire([email protected]/AbstractQueuedSynchronizer.java:715)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire([email protected]/AbstractQueuedSynchronizer.java:938)
at
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock([email protected]/ReentrantReadWriteLock.java:959)
at
org.apache.doris.qe.VariableMgr.newSessionVariable(VariableMgr.java:259)
at org.apache.doris.qe.ConnectContext.init(ConnectContext.java:384)
at org.apache.doris.qe.ConnectContext.<init>(ConnectContext.java:422)
at org.apache.doris.qe.ConnectContext.<init>(ConnectContext.java:402)
at org.apache.doris.qe.ConnectContext.<init>(ConnectContext.java:398)
at
org.apache.doris.load.StreamLoadHandler.setCloudCluster(StreamLoadHandler.java:118)
at
org.apache.doris.service.FrontendServiceImpl.streamLoadPut(FrontendServiceImpl.java:2127)
at jdk.internal.reflect.GeneratedMethodAccessor24.invoke(Unknown
Source)
at
jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke([email protected]/DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke([email protected]/Method.java:568)
at org.apache.doris.service.FeServer.lambda$start$0(FeServer.java:60)
at
org.apache.doris.service.FeServer$$Lambda$316/0x00007ec0b880cb60.invoke(Unknown
Source)
at jdk.proxy2.$Proxy46.streamLoadPut(jdk.proxy2/Unknown Source)
at
org.apache.doris.thrift.FrontendService$Processor$streamLoadPut.getResult(FrontendService.java:4832)
at
org.apache.doris.thrift.FrontendService$Processor$streamLoadPut.getResult(FrontendService.java:4812)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38)
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:250)
at
java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1136)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:635)
at java.lang.Thread.run([email protected]/Thread.java:840)
"thrift-server-pool-48" #535 daemon prio=5 os_prio=0 cpu=3502.35ms
elapsed=895.28s tid=0x00007ebbc0030d60 nid=0x3244ab waiting on condition
[0x00007eb7059d8000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x00007ec62e946238> (a
java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at
java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:211)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire([email protected]/AbstractQueuedSynchronizer.java:715)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire([email protected]/AbstractQueuedSynchronizer.java:938)
at
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock([email protected]/ReentrantReadWriteLock.java:959)
at
org.apache.doris.qe.VariableMgr.newSessionVariable(VariableMgr.java:259)
at org.apache.doris.qe.ConnectContext.init(ConnectContext.java:384)
at org.apache.doris.qe.ConnectContext.<init>(ConnectContext.java:422)
at org.apache.doris.qe.ConnectContext.<init>(ConnectContext.java:402)
at org.apache.doris.qe.ConnectContext.<init>(ConnectContext.java:398)
at
org.apache.doris.load.StreamLoadHandler.setCloudCluster(StreamLoadHandler.java:118)
at
org.apache.doris.service.FrontendServiceImpl.streamLoadPut(FrontendServiceImpl.java:2127)
at jdk.internal.reflect.GeneratedMethodAccessor24.invoke(Unknown
Source)
at
jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke([email protected]/DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke([email protected]/Method.java:568)
at org.apache.doris.service.FeServer.lambda$start$0(FeServer.java:60)
at
org.apache.doris.service.FeServer$$Lambda$316/0x00007ec0b880cb60.invoke(Unknown
Source)
at jdk.proxy2.$Proxy46.streamLoadPut(jdk.proxy2/Unknown Source)
at
org.apache.doris.thrift.FrontendService$Processor$streamLoadPut.getResult(FrontendService.java:4832)
at
org.apache.doris.thrift.FrontendService$Processor$streamLoadPut.getResult(FrontendService.java:4812)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38)
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:250)
at
java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1136)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:635)
at java.lang.Thread.run([email protected]/Thread.java:840)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
