unomi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "396859442" <396859...@qq.com>
Subject 回复: How to create a unomi cluster ?
Date Tue, 23 Jun 2020 09:56:06 GMT
Hello
&nbsp; &nbsp; &nbsp;Thank for your letter。 I had deploy 2 unomi server cluster
on the following machine.
&nbsp; &nbsp; &nbsp; &nbsp; 1.&nbsp; 4core 8 thread&nbsp; &nbsp;32G
memory 2T disk
&nbsp; &nbsp; &nbsp; &nbsp; 2.&nbsp; 4core 8 thread&nbsp; &nbsp;32G
memory 2T disk
&nbsp; &nbsp;&nbsp;When I use the pressure test tool (https://github.com/rakyll/hey&nbsp;)
to test the context.js endpoint, (hey -n 20000 -c 5000&nbsp; xxx/context.js?xxx )
&nbsp; &nbsp; &nbsp;I encounter the following problem, I think this should be
a problem of ES thread pool parameters, but I have not found a place where these parameters
can be configured.
&nbsp; &nbsp; &nbsp;If you know, please tell me . Thanks.&nbsp;
log
```
2020-06-23T16:18:43,871 | ERROR | qtp1635384517-574 | ElasticSearchPersistenceServiceImpl
| 173 - org.apache.unomi.persistence-elasticsearch-core - 1.4.0 | Error while executing in
class loader
org.elasticsearch.common.util.concurrent.EsRejectedExecutionException: rejected execution
of org.elasticsearch.transport.TransportService$7@2da770fd on EsThreadPoolExecutor[bulk, queue
capacity = 200, org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@18f06609[Running,
pool size = 8, active threads = 8, queued tasks = 200, completed tasks = 183245]]
	at org.elasticsearch.common.util.concurrent.EsAbortPolicy.rejectedExecution(EsAbortPolicy.java:50)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:?]
	at org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor.doExecute(EsThreadPoolExecutor.java:94)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor.execute(EsThreadPoolExecutor.java:89)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TransportService.sendLocalRequest(TransportService.java:640)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TransportService.access$000(TransportService.java:74) ~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TransportService$3.sendRequest(TransportService.java:137)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TransportService.sendRequestInternal(TransportService.java:586)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:519) ~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TransportService.sendRequest(TransportService.java:507) ~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction$ReroutePhase.performAction(TransportReplicationAction.java:780)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction$ReroutePhase.performLocalAction(TransportReplicationAction.java:698)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction$ReroutePhase.doRun(TransportReplicationAction.java:686)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction.doExecute(TransportReplicationAction.java:143)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction.doExecute(TransportReplicationAction.java:92)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.TransportAction$RequestFilterChain.proceed(TransportAction.java:170)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.TransportAction.execute(TransportAction.java:142) ~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction$OperationTransportHandler.messageReceived(TransportReplicationAction.java:218)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.action.support.replication.TransportReplicationAction$OperationTransportHandler.messageReceived(TransportReplicationAction.java:215)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.RequestHandlerRegistry.processMessageReceived(RequestHandlerRegistry.java:69)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TcpTransport$RequestHandler.doRun(TcpTransport.java:1539)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.common.util.concurrent.EsExecutors$1.execute(EsExecutors.java:110) ~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TcpTransport.handleRequest(TcpTransport.java:1496) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.TcpTransport.messageReceived(TcpTransport.java:1379) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at org.elasticsearch.transport.netty4.Netty4MessageChannelHandler.channelRead(Netty4MessageChannelHandler.java:74)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:297)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:413)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
~[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.handler.logging.LoggingHandler.channelRead(LoggingHandler.java:241) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:544) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:498) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458) [173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
[173:org.apache.unomi.persistence-elasticsearch-core:1.4.0]
	at java.lang.Thread.run(Thread.java:748) [?:?]

```





Regards
&nbsp;pengpeng














------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"Serge Huber"<shuber@jahia.com&gt;;
发送时间:&nbsp;2020年6月19日(星期五) 下午5:51
收件人:&nbsp;"users"<users@unomi.apache.org&gt;;

主题:&nbsp;Re: How to create a unomi cluster ?



Hello,

Have you started the unomi bundles using the unomi:start command ?


Regards,
&nbsp; Serge...&nbsp;

Serge Huber
CTO &amp; Co-Founder

T +41 22 361 3424
9 route des Jeunes | 1227 Acacias | Switzerland
jahia.com
SKYPE&nbsp;|&nbsp;LINKEDIN&nbsp;|&nbsp;TWITTER&nbsp;|&nbsp;VCARD

&nbsp;&nbsp;


&gt; JOIN OUR COMMUNITY&nbsp;to evaluate, get trained and to discover why Jahia is
a leading User Experience Platform (UXP) for Digital Transformation.
















On Fri, Jun 19, 2020 at 4:19 AM 396859442 <396859442@qq.com&gt; wrote:


Hi Mr/Mrs:

&nbsp;I want to build a cluster of unomi , so ,I have done as document say's, but the
cluster can't receive event !

These cluster don't work normal, thesr Krafa client can't use the unomi* commnad. However
,the /cxs endpoints

is fine.&nbsp; So, what should I do ? Pleas help me if you kown something.





Thanks.
Mime
View raw message