You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by "Serge Huber (Jira)" <ji...@apache.org> on 2020/03/24 15:06:00 UTC
[jira] [Commented] (UNOMI-298) UNOMI doesn't connect to
Elasticsearch Cluster
[ https://issues.apache.org/jira/browse/UNOMI-298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065868#comment-17065868 ]
Serge Huber commented on UNOMI-298:
-----------------------------------
Unomi 1.4 is not compatible with ElasticSearch 7.4.2 you need ES 5.6.3 for that.
Please see the instructions here:
http://unomi.apache.org/get-started.html
> UNOMI doesn't connect to Elasticsearch Cluster
> ----------------------------------------------
>
> Key: UNOMI-298
> URL: https://issues.apache.org/jira/browse/UNOMI-298
> Project: Apache Unomi
> Issue Type: Bug
> Reporter: Andrés Páez
> Priority: Major
>
> Hello,
> I'm having problems while trying to start UNOMI, with the following setup:
>
> *UNOMI 1.4:*
> Server 1: UNOMI Server.
>
> *Cluster ELASTICSEARCH 7.4.2:*
> Server1: Master
> Server2: Data
> Server3: Data
>
> The configuration changed for UNOMI is the following:
> In /etc/custom.system.properties
> {code:java}
> // code placeholder
> org.apache.unomi.elasticsearch.cluster.name=${env:UNOMI_ELASTICSEARCH_CLUSTERNAME:-mdmElasticsearch}# The elasticSearchAddresses may be a comma seperated list of host names and ports such as
> # hostA:9300,hostB:9300
> # Note: the port number must be repeated for each host.
> # org.apache.unomi.elasticsearch.addresses=${env:UNOMI_ELASTICSEARCH_ADDRESSES:-localhost:9300}
> org.apache.unomi.elasticsearch.addresses=${env:UNOMI_ELASTICSEARCH_ADDRESSES:-elasticsearch1:9200,elasticsearch2:9200,elasticsearch3:9200}org.apache.unomi.elasticsearch.index.name=${env:UNOMI_ELASTICSEARCH_INDEXNAME:-context}
> org.apache.unomi.elasticsearch.monthlyIndex.nbShards=${env:UNOMI_ELASTICSEARCH_MONTHLYINDEX_SHARDS:-5}
> org.apache.unomi.elasticsearch.monthlyIndex.nbReplicas=${env:UNOMI_ELASTICSEARCH_MONTHLYINDEX_REPLICAS:-0}
> org.apache.unomi.elasticsearch.defaultIndex.nbShards=${env:UNOMI_ELASTICSEARCH_DEFAULTINDEX_SHARDS:-5}
> org.apache.unomi.elasticsearch.defaultIndex.nbReplicas=${env:UNOMI_ELASTICSEARCH_DEFAULTINDEX_REPLICAS:-0}
> org.apache.unomi.elasticsearch.defaultQueryLimit=${env:UNOMI_ELASTICSEARCH_DEFAULTQUERYLIMIT:-10}
> org.apache.unomi.elasticsearch.aggregateQueryBucketSize=${env:UNOMI_ELASTICSEARCH_AGGREGATEBUCKETSIZE:-5000}
> org.apache.unomi.elasticsearch.maximumIdsQueryCount=${env:UNOMI_ELASTICSEARCH_MAXIMUMIDSQUERYCOUNT:-5000}
> {code}
> The elasticsearch cluster is working and in green.
> The error that shows when failing to Initialize unomi:
> {code:java}
> // code placeholder
> 15:55:36.570 [elasticsearch[_client_][transport_client_boss][T#2]] WARN org.elasticsearch.transport.netty4.Netty4Transport - exception caught on transport layer [[id: 0x78a7d0c1, L:/unomi-server:36390 ! R:/elasticsearch1:9200]], closing connection
> io.netty.handler.codec.DecoderException: java.io.StreamCorruptedException: invalid internal transport message format, got (48,54,54,50)
> at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:459) ~[!/:?]
> at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:392) ~[!/:?]
> at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:359) ~[!/:?]
> at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:342) ~[!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224) [!/:?]
> at io.netty.handler.logging.LoggingHandler.channelInactive(LoggingHandler.java:167) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224) [!/:?]
> at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1329) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245) [!/:?]
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231) [!/:?]
> at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:908) [!/:?]
> at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:744) [!/:?]
> at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [!/:?]
> at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403) [!/:?]
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462) [!/:?]
> at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) [!/:?]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_242]
> {code}
> When executing tail:logs, this is the error that is showing:
> {code:java}
> // code placeholder
> Caused by: org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: [{#transport#-1}{UyL1zuYYSpqxqgmi0vXCmQ}{elasticserver1}{elasticserver1:9200}, {#transport#-2}{tIDkmd-aSJOGeCku7sEhvw}{elasticserver2}{elasticserver2:9200}, {#transport#-3}{yiOQmS86QwGHZcCuSmgtlw}{elasticserver3}{elasticserver3:9200}]
> at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:347) ~[?:?]
> at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:245) ~[?:?]
> at org.elasticsearch.client.transport.TransportProxyClient.execute(TransportProxyClient.java:59) ~[?:?]
> at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:363) ~[?:?]
> at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:408) ~[?:?]
> at org.elasticsearch.client.support.AbstractClient$ClusterAdmin.execute(AbstractClient.java:730) ~[?:?]
> at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:80) ~[?:?]
> at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:54) ~[?:?]
> at org.apache.unomi.persistence.elasticsearch.ElasticSearchPersistenceServiceImpl$1.execute(ElasticSearchPersistenceServiceImpl.java:354) ~[?:?]
> at org.apache.unomi.persistence.elasticsearch.ElasticSearchPersistenceServiceImpl$InClassLoaderExecute.executeInClassLoader(ElasticSearchPersistenceServiceImpl.java:1887) ~[?:?]
> at org.apache.unomi.persistence.elasticsearch.ElasticSearchPersistenceServiceImpl.start(ElasticSearchPersistenceServiceImpl.java:430) ~[?:?]
> 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.aries.blueprint.utils.ReflectionUtils.invoke(ReflectionUtils.java:299) ~[?:?]
> at org.apache.aries.blueprint.container.BeanRecipe.invoke(BeanRecipe.java:980) ~[?:?]
> at org.apache.aries.blueprint.container.BeanRecipe.runBeanProcInit(BeanRecipe.java:736) ~[?:?]
> at org.apache.aries.blueprint.container.BeanRecipe.internalCreate2(BeanRecipe.java:848) ~[?:?]
> at org.apache.aries.blueprint.container.BeanRecipe.internalCreate(BeanRecipe.java:811) ~[?:?]
> at org.apache.aries.blueprint.di.AbstractRecipe$1.call(AbstractRecipe.java:79) ~[?:?]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:?]
> at org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:88) ~[?:?]
> at org.apache.aries.blueprint.di.RefRecipe.internalCreate(RefRecipe.java:62) ~[?:?]
> at org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:106) ~[?:?]
> at org.apache.aries.blueprint.container.ServiceRecipe.createService(ServiceRecipe.java:285) ~[?:?]
> {code}
> Do I have to configure something else?
>
> Regards
--
This message was sent by Atlassian Jira
(v8.3.4#803005)