You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@unomi.apache.org by 396859442 <39...@qq.com> on 2020/06/23 09:56:06 UTC
回复： How to create a unomi cluster ?

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.